[ https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625746#comment-17625746 ]
Durgesh Mishra commented on FLINK-29711: ---------------------------------------- [~martijnvisser] I checked with microsoft Azure Eventhub side of things, but sadly no luck they showed me everything working well on their side. Do you guys can suggest something on this ? If possible we can have call to discuss this problem sometime. What's your thought ? > Topic notification not present in metadata after 60000 ms. > ---------------------------------------------------------- > > Key: FLINK-29711 > URL: https://issues.apache.org/jira/browse/FLINK-29711 > Project: Flink > Issue Type: Bug > Components: Connectors / Kafka > Affects Versions: 1.14.4, 1.14.6 > Reporter: Durgesh Mishra > Priority: Major > > Failed to send data to Kafka null with > FlinkKafkaInternalProducer\{transactionalId='null', inTransaction=false, > closed=false} > at > org.apache.flink.connector.kafka.sink.KafkaWriter$WriterCallback.throwException(KafkaWriter.java:405) > at > org.apache.flink.connector.kafka.sink.KafkaWriter$WriterCallback.lambda$onCompletion$0(KafkaWriter.java:391) > at > org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50) > at org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90) > at > org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsNonBlocking(MailboxProcessor.java:353) > at > org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:317) > at > org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:201) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:809) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:761) > at > org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) > at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937) > at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766) > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) > at java.base/java.lang.Thread.run(Unknown Source) -- This message was sent by Atlassian Jira (v8.20.10#820010)