![]() client: client which keeps a connection with the Kafka server.įetch the available offset of a specific topic-partition.If autoCommit is enabled calling close will also commit offsets consumed from the buffer. force a commit even if there's a pending commitĬloses the ConsumerGroup.sslOptions: Object, options to be passed to the tls broker sockets, ex.maxAsyncRequests : maximum async operations at a time toward the kafka cluster.reconnectOnIdle : when the connection is closed due to client idling, client will attempt to auto-reconnect.The value is elapsed time in ms without any data written to the TCP socket. idleConnection : allows the broker to disconnect an idle connection from a client (otherwise the clients continues to O after being disconnected).connectRetryOptions : object hash that applies to the initial connection.autoConnect : automatically connect when KafkaClient is instantiated otherwise you need to manually call connect default: true.requestTimeout : in ms for a kafka request to timeout default: 30000.connectTimeout : in ms it takes to wait for a successful connection before moving to the next host default: 10000.kafkaHost : A string of kafka broker/host combination delimited by comma for example: :9093,:9093,:9093 default: localhost:9092.New KafkaClient connects directly to Kafka brokers. Connect directly to brokers (Kafka 0.9+)įollow the instructions on the Kafka wiki to build Kafka and get a test broker up and running.Consumer Groups managed by Kafka coordinator (Kafka 0.9+).SASL/PLAIN Authentication (Kafka 0.10+).SSL connections to brokers (Kafka 0.9+).Node Stream Consumers (ConsumerGroupStream Kafka 0.9+).What are these node-gyp and snappy errors?.How do I produce and consume binary data?. #NODEJS KAFKA HOW TO#How to throttle messages / control the concurrency of processing messages.ConsumerGroup does not consume on all partitions.For a new consumer how do I start consuming from the latest message in a partition?.HighLevelProducer with KeyedPartitioner errors on first send.Kafka-node is a Node.js client for Apache Kafka 0.9 and later. ![]()
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |