search

vdesabou / kafka-docker-playground

🐳✨ Fully automated Apache Kafka® and Confluent Docker based examples // 👷‍♂️ Easily build examples or reproduction models
https://kafka-docker-playground.io
MIT License
637 stars 206 forks source link

🔥 connect/connect-azure-event-hubs-source #5744

Closed vdesabou closed 2 weeks ago

vdesabou commented 3 weeks ago

🆕💥 New issue !

🔥 CP 7.6.1 🔢 Connector v2.0.7 (📅 release date 2024-06-21) 🕐 2024-07-07 18:33 📄 azure-event-hubs-source.sh 🔗 https://github.com/vdesabou/kafka-docker-playground/actions/runs/9829380159/job/27134466591

vdesabou commented 3 weeks ago

🤦‍♂️💥 Still failing !

🔥 CP 7.6.1 🔢 Connector v2.0.7 (📅 release date 2024-06-21) 🕐 2024-07-08 18:34 📄 azure-event-hubs-source.sh 🔗 https://github.com/vdesabou/kafka-docker-playground/actions/runs/9844853349/job/27179528766

vdesabou commented 2 weeks ago

🤦‍♂️💥 Still failing !

🔥 CP 7.6.1 🔢 Connector v2.0.7 (📅 release date 2024-06-21) 🕐 2024-07-09 18:33 📄 azure-event-hubs-source.sh 🔗 https://github.com/vdesabou/kafka-docker-playground/actions/runs/9862187102/job/27232597292

vdesabou commented 2 weeks ago

🤦‍♂️💥 Still failing !

🔥 CP 7.6.1 🔢 Connector v2.0.7 (📅 release date 2024-06-21) 🕐 2024-07-10 18:36 📄 azure-event-hubs-source.sh 🔗 https://github.com/vdesabou/kafka-docker-playground/actions/runs/9879426791/job/27286060664

vdesabou commented 2 weeks ago 
***-event-hubs-source        ✅ RUNNING  0:🛑 FAILED[connect]          tasks: org.apache.kafka.connect.errors.ConnectException: Another Entity is polling data from the same consumer group
    at io.confluent.connect.***.eventhubs.EventHubsSourceTask.throwSameConsumerGroupError(EventHubsSourceTask.java:269)
    at io.confluent.connect.***.eventhubs.EventHubsSourceTask.populateReceivers(EventHubsSourceTask.java:332)
    at io.confluent.connect.***.eventhubs.EventHubsSourceTask.setupReceivers(EventHubsSourceTask.java:202)
    at io.confluent.connect.***.eventhubs.EventHubsSourceTask.start(EventHubsSourceTask.java:160)
    at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.initializeAndStart(AbstractWorkerSourceTask.java:283)
    at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:227)
    at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:284)
    at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:80)
    at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:237)
    at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
    at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
    at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
    at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
    at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: com.microsoft.***.eventhubs.ReceiverDisconnectedException: Receiver 'nil' with a higher epoch '172037[719](https://github.com/vdesabou/kafka-docker-playground/actions/runs/9879426791/job/27286060664#step:6:720)8275' already exists. Receiver 'nil' with epoch 1720377197601 cannot be created. Make sure you are creating receiver with increasing epoch value to ensure connectivity, or ensure all old epoch receivers are closed or disconnected. TrackingId:9356956a-5e32-4966-b3c4-87f759411003_B39, SystemTracker:nspgrunnereh1272761:eventhub:hubpgrunnereh1272761~8191|$default, Timestamp:2024-07-07T18:33:18 Reference:15509ad0-ff9e-47ac-acdd-6be6bd3a096e, TrackingId:85c28016-c533-41a6-b55d-3cd34ff589a4_B39, SystemTracker:nspgrunnereh1272761:eventhub:hubpgrunnereh1272761~8191|$default, Timestamp:2024-07-07T18:33:18 TrackingId:648eff41c6d24ccca4d7bddcccf3c814_G18, SystemTracker:gateway5, Timestamp:2024-07-07T18:33:18, errorContext[NS: nspgrunnereh1272761.servicebus.windows.net, PATH: hubpgrunnereh1272761/ConsumerGroups/$Default/Partitions/0, REFERENCE_ID: LN_945285_1[720](https://github.com/vdesabou/kafka-docker-playground/actions/runs/9879426791/job/27286060664#step:6:721)377198563_814_G18]
    at com.microsoft.***.eventhubs.impl.ExceptionUtil.toException(ExceptionUtil.java:43)
    at com.microsoft.***.eventhubs.impl.MessageReceiver.onClose(MessageReceiver.java:789)
    at com.microsoft.***.eventhubs.impl.BaseLinkHandler.processOnClose(BaseLinkHandler.java:73)
    at com.microsoft.***.eventhubs.impl.BaseLinkHandler.handleRemoteLinkClosed(BaseLinkHandler.java:109)
    at com.microsoft.***.eventhubs.impl.BaseLinkHandler.onLinkRemoteClose(BaseLinkHandler.java:51)
    at org.apache.qpid.proton.engine.BaseHandler.handle(BaseHandler.java:176)
    at org.apache.qpid.proton.engine.impl.EventImpl.dispatch(EventImpl.java:108)
    at org.apache.qpid.proton.reactor.impl.ReactorImpl.dispatch(ReactorImpl.java:324)
    at org.apache.qpid.proton.reactor.impl.ReactorImpl.process(ReactorImpl.java:291)
    at com.microsoft.***.eventhubs.impl.MessagingFactory$RunReactor.run(MessagingFactory.java:784)
    at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
    at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
    at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
    ... 3 more
vdesabou commented 2 weeks ago

👍✅ Issue fixed !

👍 CP 7.6.1 🔢 Connector v2.0.7 (📅 release date 2024-06-21) 🕐 2024-07-11 18:36 📄 azure-event-hubs-source.sh 🔗 https://github.com/vdesabou/kafka-docker-playground/actions/runs/9896512696/job/27339296361