[
https://issues.apache.org/jira/browse/KAFKA-8281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nitin Patidar updated KAFKA-8281:
---------------------------------
Priority: Critical (was: Major)
> 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
> Priority: Critical
> 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)
