Hello
We want to connect one Kafka machine with Splunk connect for Kafka but it's throwing the below error in file: config/connect-distributed.properties.
[Worker clientId=connect-1, groupId=MySuperSystemID_group] Uncaught exception in herder work thread, exiting: (org.apache.kafka.connect.runtime.distributed.DistributedHerder:324)
org.apache.kafka.connect.errors.ConnectException: Could not look up partition metadata for offset backing store topic in allotted period. This could indicate a connectivity issue, unavailable topic partitions, or if this is your first use of the topic it may have taken too long to create.
at org.apache.kafka.connect.util.KafkaBasedLog.start(KafkaBasedLog.java:184)
at org.apache.kafka.connect.storage.KafkaOffsetBackingStore.start(KafkaOffsetBackingStore.java:145)
at org.apache.kafka.connect.runtime.Worker.start(Worker.java:197)
at org.apache.kafka.connect.runtime.AbstractHerder.startServices(AbstractHerder.java:128)
at org.apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:310)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
The configuration looks like this:
group.id=MySuperSystemID_group
bootstrap.servers=https://x.x.x.x:9093
#key.converter=org.apache.kafka.connect.storage.StringConverter
#value.converter=org.apache.kafka.connect.storage.StringConverter
# SSL Configuration
security.protocol=SSL
ssl.client.auth=required # enable two way SSL
ssl.endpoint.identification.algorithm =
ssl.key.password=password
ssl.keystore.location=/root/files/keystore.jks
ssl.keystore.password=password
ssl.keystore.type = JKS
ssl.truststore.location=/root/files/truststore.jks
ssl.truststore.password=password
ssl.enabled.protocols=TLSv1.2,TLSv1.1
ssl.truststore.type=JKS
Can someone please guide me over here?
