Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-89

Extract base Docker image for Kafka Connect with no connectors

XMLWordPrintable

    • Icon: Enhancement Enhancement
    • Resolution: Done
    • Icon: Major Major
    • 0.3
    • None
    • None
    • None

      Please offer a more recent version of Kafka (v0.10.0.0) in Docker, that plays better with Kafka Connect.

      For example, when I try to use debezium/connect:0.2 with debezium/kafka:0.2, I get an error about connect being unable to read topic metadata.

      Source:

      https://github.com/mcandre/hello-kafka-connect

      Trace:

      connect_1    | [2016-07-27 14:41:20,832] ERROR Uncaught exception in herder work thread, exiting:  (org.apache.kafka.connect.runtime.distributed.DistributedHerder:183)
connect_1    | org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'topic_metadata': java.nio.BufferUnderflowException
connect_1    | 	at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:73)
connect_1    | 	at org.apache.kafka.clients.NetworkClient.parseResponse(NetworkClient.java:380)
connect_1    | 	at org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:449)
connect_1    | 	at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:269)
connect_1    | 	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll(ConsumerNetworkClient.java:360)
connect_1    | 	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:224)
connect_1    | 	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:178)
connect_1    | 	at org.apache.kafka.clients.consumer.internals.Fetcher.getTopicMetadata(Fetcher.java:205)
connect_1    | 	at org.apache.kafka.clients.consumer.KafkaConsumer.partitionsFor(KafkaConsumer.java:1272)
connect_1    | 	at org.apache.kafka.connect.util.KafkaBasedLog.start(KafkaBasedLog.java:131)
connect_1    | 	at org.apache.kafka.connect.storage.KafkaOffsetBackingStore.start(KafkaOffsetBackingStore.java:86)
connect_1    | 	at org.apache.kafka.connect.runtime.Worker.start(Worker.java:121)
connect_1    | 	at org.apache.kafka.connect.runtime.AbstractHerder.startServices(AbstractHerder.java:105)
connect_1    | 	at org.apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:171)
connect_1    | 	at java.lang.Thread.run(Thread.java:745)

              rhauch Randall Hauch (Inactive)
              mcandre Andrew Pennebaker (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

                Created:
                Updated:
                Resolved: