You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Nitin Patidar (JIRA)" <ji...@apache.org> on 2019/04/23 17:05:00 UTC
[jira] [Created] (KAFKA-8281) Kstream hung and doing nothing
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)