Кафка не может создавать внутренние темы после 32 созданных тем - PullRequest
0 голосов
/ 04 июля 2018

У нас есть 9 микросервисов, которые создают 32 тем (2 из них с начала, 30 из них из внутренних), после того, как я создаю новое соединение, kafka выходит из строя. Есть ли какие-либо ограничения на то, что с помощью Kafka можно создавать только 32 тем или как я могу решить эту проблему?

Спасибо за ваше время.

Started SpringBootCounterMS in 4.652 seconds (JVM running for 7.59)
2018-07-04 10:39:29.513  INFO 14956 --- [-StreamThread-1] o.a.k.s.p.internals.StreamThread         : stream-thread [counter-service-3ca6bb7e-addd-445e-a22b-8b7be1b3b6c7-StreamThread-1] State transition from PARTITIONS_ASSIGNED to RUNNING
2018-07-04 10:39:29.514  INFO 14956 --- [-StreamThread-1] org.apache.kafka.streams.KafkaStreams    : stream-client [counter-service-3ca6bb7e-addd-445e-a22b-8b7be1b3b6c7]State transition from REBALANCING to RUNNING
2018-07-04 10:39:30.579  INFO 14956 --- [-StreamThread-1] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=counter-service-3ca6bb7e-addd-445e-a22b-8b7be1b3b6c7-StreamThread-1-consumer, groupId=counter-service] Marking the coordinator localhost:9092 (id: 2147483647 rack: null) dead
2018-07-04 10:39:30.599  WARN 14956 --- [-StreamThread-2] o.a.k.s.p.i.InternalTopicManager         : stream-thread [main] Could not create internal topics: Empty response for client request. Retry #0

1 Ответ

0 голосов
/ 04 июля 2018

Обновление JVM до 64-битной решает эту проблему. Это ошибка памяти.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...