6
के लिए मृत के रूप में चिह्नित मैं कोई विषय (काफ्का संस्करण 0.10.0.1) जो ठीक काम करता है अगर मैं उन्हें डोकर कंटेनर के बाहर चलने के संदेशों का उपयोग करने के लिए जावा उपभोक्ता उपयोग कर रहा हूँ, लेकिन मैं तो डोकर कंटेनर में उन्हें अमल समूह संदेशकाफ्का जावा उपभोक्ता समूह
समन्वयक local.kafka.com:9092 अंकन (: 2147483647 रैक: आईडी शून्य) के साथ मृत के रूप में चिह्नित कर रहे हैं समूह मेरे समूह
मेरे उपभोक्ता विन्यास के लिए मर चुके हैं इस प्रकार है: -
metadata.max.age.ms = 300000
partition.assignment.strategy =[org.apache.kafka.clients.consumer.RangeAssignor]
reconnect.backoff.ms = 50
sasl.kerberos.ticket.renew.window.factor = 0.8
max.partition.fetch.bytes = 1048576
bootstrap.servers = [192.168.115.128:9092, 192.168.115.128:9093]
ssl.keystore.type = JKS
enable.auto.commit = true
sasl.mechanism = GSSAPI
interceptor.classes = null
exclude.internal.topics = true
ssl.truststore.password = null
client.id = consumer-1
ssl.endpoint.identification.algorithm = null
max.poll.records = 2147483647
check.crcs = true
request.timeout.ms = 40000
heartbeat.interval.ms = 3000
auto.commit.interval.ms = 5000
receive.buffer.bytes = 65536
ssl.truststore.type = JKS
ssl.truststore.location = null
ssl.keystore.password = null
fetch.min.bytes = 1
send.buffer.bytes = 131072
value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
group.id = my-group
retry.backoff.ms = 100
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
ssl.trustmanager.algorithm = PKIX
ssl.key.password = null
fetch.max.wait.ms = 500
sasl.kerberos.min.time.before.relogin = 60000
connections.max.idle.ms = 540000
session.timeout.ms = 30000
metrics.num.samples = 2
key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
ssl.protocol = TLS
ssl.provider = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
ssl.keystore.location = null
ssl.cipher.suites = null
security.protocol = PLAINTEXT
ssl.keymanager.algorithm = SunX509
metrics.sample.window.ms = 30000
auto.offset.reset = earliest
ऑटो प्रतिबद्ध संपत्ति fals के लिए सेट है ई और मतदान समय सीमा 10000 पर सेट है, क्या कोई कृपया बता सकता है कि मैं कहां गलत कर रहा हूं।
क्या आपने इसे हल किया है? – forhas