Nitin Patidar created KAFKA-8281:
------------------------------------
Summary: Kstream hung and doing nothing
Key: KAFKA-8281
URL: https://issues.apache.org/jira/browse/KAFKA-8281
Project: Kafka
Issue Type: Bug
Reporter: Nitin Patidar
Fix For: 2.2.0
After re balancing, kstream is doing nothing and it hung. Below is the log for
the issue
2019-04-16 19:30:12.193 INFO
[patient-importexternalpatient,,,,1210e872-c8a5-4c00-bd9c-775782bec3a8] 8 ---
[ntainer#0-8-C-1] i.c.k.s.KafkaAvroSerializerConfig : KafkaAvroSerializerConfig
values:
schema.registry.url = [https://ula-anurxsr01.walgreens.com:8443]
basic.auth.user.info = [hidden]
auto.register.schemas = true
max.schemas.per.subject = 1000
basic.auth.credentials.source = URL
schema.registry.basic.auth.user.info = [hidden]
value.subject.name.strategy = class
io.confluent.kafka.serializers.subject.TopicNameStrategy
key.subject.name.strategy = class
io.confluent.kafka.serializers.subject.TopicNameStrategy
2019-04-16 19:30:18.434 INFO
[patient-importexternalpatient,,,,1210e872-c8a5-4c00-bd9c-775782bec3a8] 8 ---
[ntainer#0-8-C-1] s.k.l.ConcurrentMessageListenerContainer : partitions
assigned: [uat-patient_import-1]
2019-04-16 19:30:34.918 INFO [patient-importexternalpatient,,,,] 8 ---
[-StreamThread-8] i.c.k.s.KafkaAvroSerializerConfig : KafkaAvroSerializerConfig
values:
schema.registry.url = [https://ula-anurxsr01.walgreens.com:8443]
basic.auth.user.info = [hidden]
auto.register.schemas = true
max.schemas.per.subject = 1000
basic.auth.credentials.source = URL
schema.registry.basic.auth.user.info = [hidden]
value.subject.name.strategy = class
io.confluent.kafka.serializers.subject.TopicNameStrategy
key.subject.name.strategy = class
io.confluent.kafka.serializers.subject.TopicNameStrategy
2019-04-16 19:30:34.918 INFO [patient-importexternalpatient,,,,] 8 ---
[-StreamThread-8] i.c.k.s.KafkaAvroDeserializerConfig :
KafkaAvroDeserializerConfig values:
schema.registry.url = [https://ula-anurxsr01.walgreens.com:8443]
basic.auth.user.info = [hidden]
auto.register.schemas = true
max.schemas.per.subject = 1000
basic.auth.credentials.source = URL
schema.registry.basic.auth.user.info = [hidden]
specific.avro.reader = true
value.subject.name.strategy = class
io.confluent.kafka.serializers.subject.TopicNameStrategy
key.subject.name.strategy = class
io.confluent.kafka.serializers.subject.TopicNameStrategy
2019-04-16 19:30:34.918 INFO [patient-importexternalpatient,,,,] 8 ---
[-StreamThread-8] i.c.k.s.KafkaAvroSerializerConfig : KafkaAvroSerializerConfig
values:
schema.registry.url = [https://ula-anurxsr01.walgreens.com:8443]
basic.auth.user.info = [hidden]
auto.register.schemas = true
max.schemas.per.subject = 1000
basic.auth.credentials.source = URL
schema.registry.basic.auth.user.info = [hidden]
value.subject.name.strategy = class
io.confluent.kafka.serializers.subject.TopicNameStrategy
key.subject.name.strategy = class
io.confluent.kafka.serializers.subject.TopicNameStrategy
2019-04-16 19:30:34.918 INFO [patient-importexternalpatient,,,,] 8 ---
[-StreamThread-8] i.c.k.s.KafkaAvroDeserializerConfig :
KafkaAvroDeserializerConfig values:
schema.registry.url = [https://ula-anurxsr01.walgreens.com:8443]
basic.auth.user.info = [hidden]
auto.register.schemas = true
max.schemas.per.subject = 1000
basic.auth.credentials.source = URL
schema.registry.basic.auth.user.info = [hidden]
specific.avro.reader = true
value.subject.name.strategy = class
io.confluent.kafka.serializers.subject.TopicNameStrategy
key.subject.name.strategy = class
io.confluent.kafka.serializers.subject.TopicNameStrategy
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
