Python error after upgrading confluent-kafka library

2020-08-25 Thread Kafka Shil
I upgraded confluent-kafka from 1.0.1 to 1.4.2. After upgrading, if I execute 'pip install' I am getting the following error. I am using python 2.7. Has anyone else encountered this issue? Traceback (most recent call last):import confluent_kafka as kafkaFile "/home/sshil/virtual_envs/ma_venv/local

Kafka consumer is taking time to recognize new partition

2020-05-20 Thread Kafka Shil
I was running a test where kafka consumer was reading data from multiple partitions of a topic. While the process was running I added more partitions. It took around 5 minutes for consumer thread to read data from the new partition. I have found this configuration " topic.metadata.refresh.interval.

Re: How to change schema registry port

2019-12-25 Thread Kafka Shil
On Wed, Dec 25, 2019 at 5:51 PM Kafka Shil wrote: > Hi, > I am using docker compose file to start schema-registry. I need to change > default port to 8084 instead if 8081. I made the following changes in > docker compose file. > > schema-registry: > image: confluenti