Всем привет. Возникла ошибка при транзакционнной отправке в кафку. Invalid

Question

pro.kafka

Ivan Shirokov

Всем привет. Возникла ошибка при транзакционнной отправке в кафку. Invalid

transition attempted from state IN_TRANSACTION to state IN_TRANSACTION. Кто-нибудь знает что могло это вызвать?)

#kafka #russian #software

0

17.09.2020

9 ответов

43 просмотра

Ivan Shirokov Автор вопроса

Оказалось что если поток не успел закрыть транзакцию и следующий начинает ее, то вылетает это исключение. Получается beginTransaction() не thread safe чтоли и надо синхронизировать метод?

0

17.09.2020

Ivan Shirokov Автор вопроса

M
Сингл продюсер паттерн вродь должно быть не? Или э...

Что вы имеете ввиду, может я что-то не знаю просто

0

17.09.2020

M

Ivan Shirokov
Что вы имеете ввиду, может я что-то не знаю просто

KafkaProducer<K,V> A Kafka client that publishes records to the Kafka cluster. The producer is thread safe and sharing a single producer instance across threads will generally be faster than having multiple instances. Here is a simple example of using the producer to send records with strings containing sequential numbers as the key/value pairs. https://kafka.apache.org/10/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html

0

17.09.2020

Ivan Shirokov Автор вопроса

M
KafkaProducer<K,V> A Kafka client that publishes r...

Да тут как раз написано. Can be only one open transaction per producer. Видимо надо пул создавать какой-то на старте

0

18.09.2020

Sergey Yezhov

Ivan Shirokov
Оказалось что если поток не успел закрыть транзакц...

Хай) Как в итоге сделал? Поделись решением плз, если есть возможность.

0

23.06.2022