Hi
We are facing a issue where our Consumer component is not instantly
logging the records polled from the Brokers. We have following the
below architecture as attached. Following are the properties
configured:

Producer.properties

bootstrap.servers=xx.xxx.xxx.140:9092,xx.xxx.xxx.140:9093,xx.xxx.xxx.140:9094,xx.xxx.xxx.141:9092,xx.xxx.xxx.141:9093,xx.xxx.xxx.141:9094,xx.xxx.xxx.142:9092,xx.xxx.xxx.142:9093,xx.xxx.xxx.142:9094
acknowledgement=all
group_id=kafkaClusterVLink
retries=3
batch_size=6384
linger_ms=1
buffer_memory=54432
topic=visualize-link-redirect
key.serializer=org.apache.kafka.common.serialization.StringSerializer
value.serializer=org.apache.kafka.common.serialization.StringSerializer

We send the Json String to from Producer to Borkers(Approxs 250Byte/Messsage)

Consumer.properties

bootstrap.servers=xx.xxx.xxx.140:9092,xx.xxx.xxx.140:9093,xx.xxx.xxx.140:9094,xx.xxx.xxx.141:9092,xx.xxx.xxx.141:9093,xx.xxx.xxx.141:9094,xx.xxx.xxx.142:9092,xx.xxx.xxx.142:9093,xx.xxx.xxx.142:9094
group.id=kafkaClusterVLink
enable.auto.commit=true
auto.commit.interval.ms=10000
session.timeout.ms=30000
key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
value.deserializer=org.apache.kafka.common.serialization.StringDeserializer
topic=visualize-link-redirect


Please help me to resolve this issue as soon as possible. Will be
grateful to you.







Thanks and Regards,
Navneet Kumar

Reply via email to