Search for a command to run...
Articles tagged with #kafka
install package: go get https://github.com/segmentio/kafka-go Create Topic In Kafka: create topic name logging topic logging has 1 partition Producer create folder producer: create file main.go in folder producer copy and paste code: package...
Why Selecting an appropriate hardware configuration for a Kafka broker can be more art than science. Kafka itself has no strict requirement on a specific hardware configura‐ tion, and will run without issue on any system. Once performance becomes a c...
Suppose you have an application that needs to read messages from a Kafka topic, run some validations against them, and write the results to another data store. In this case your application will create a consumer object, subscribe to the appropriate ...
The first step in writing messages to Kafka is to create a producer object with the properties you want to pass to the producer. A Kafka producer has three mandatory properties: bootstrap.servers: list of host:port pairs of brokers that the producer...
There are many reasons an application might need to write messages to Kafka: recording user activities for auditing or analysis, recording metrics, storing log mes‐ sages, recording information from smart appliances, communicating asynchronously with...
There are several factors to consider when choosing the number of partitions: What is the throughput you expect to achieve for the topic? For example, do you expect to write 100KB per second or 1 GB per second? What is the maximum throughput you ex...
![[KAFKA] How to chose the number of partitions?](https://cdn.hashnode.com/res/hashnode/image/upload/v1660315731425/O0E8xMNNJ.png)