#apache-kafka #kafka-consumer-api #kafka-producer-api
#apache-kafka #kafka-consumer-api #kafka-producer-api
Вопрос:
Я использую kafka-net sdk для создания и использования сообщений kafka. Возможность создавать и использовать сообщение, когда доступен поставщик Kafka.
Но при недоступности kafka время синхронизации SendAsync (метода KafkaConnection) не истекает даже после истечения времени ожидания ответа. На данный момент он ожидает неопределенно долго.
Как выполнить прерывание или получить исключение тайм-аута после истечения времени ожидания ответа?
Комментарии:
1. Привет, @Jayakrishna, если возможно, не могли бы вы, пожалуйста, поделиться своим примером приложения? Я новичок в kafka, поэтому хотел бы увидеть реализацию, чтобы понять kafka.