Kafka Connect при чтении с помощью нескольких тасков. Можно ли обеспечить связь таски с определенной партицией по ключу?
Вопрос на SO: https://stackoverflow.com/questions/56966712/preserve-messages-order-when-reading-from-ibm-mq-with-kafka-connect
есть конструктор с партицией org.apache.kafka.connect.source.SourceRecord#SourceRecord(java.util.Map<java.lang.String,?>, java.util.Map<java.lang.String,?>, java.lang.String, java.lang.Integer, org.apache.kafka.connect.data.Schema, java.lang.Object, org.apache.kafka.connect.data.Schema, java.lang.Object, java.lang.Long, java.lang.Iterable<org.apache.kafka.connect.header.Header>)
Обсуждают сегодня