Результаты поиска по запросу "spring-kafka"

1 ответ

это сработало, спасибо, что указал на это :)

0 ответов

Вы можете установить spring.kafka.bootstrap-servers = $ {spring.embedded.kafka.brokers} в вашем application.properties для теста, который должен работать. Он заполняется из EmbeddedKafka случайным портом, который был назначен при запуске.

ить FYI:пример работы с gitHub [https://github.com/YunaBraska/embedded-kafka-example] Я искал в интернете и не смог найти работающего и простого примера встроенного теста Кафки. Моя настройка: Весенний ...

2 ответа

Спасибо за информацию! Прямо сейчас, поскольку я также могу определять тематические разделы, я могу быть осторожным и смотреть в будущее с точки зрения емкости. но да, я буду помнить об этом инструменте на случай, если он понадобится мне в будущем.

исал одного потребителя Kafka (используя Spring Kafka), который читает из одной темы и является частью группы потребителей. Как только сообщение будет использовано, оно выполнит все последующие операции и перейдет к следующему смещению сообщения. ...

ТОП публикаций

2 ответа

Если вы хотите контролировать скорость, с которой потребитель Kafka использует Spring @KafkaListener, пожалуйста, автоматически подключите использование компонента KafkaListenerEndpointRegistry следующим образом и получите доступ к необходимому MessageListenerContainer. после этого вы можете использовать функции pause () и resume () для управления требуемым поведением.

тели использовать записи через определенный промежуток времени (например, каждые 5 минут). Потребительские свойства являются стандартными: @Bean public KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<Integer, String>> ...

3 ответа

 будет использовать нового потребителя в этом случае (но вы не можете видеть заголовки с консольным потребителем, в любом случае). Но я согласен, что странно, что потребитель может повлиять на производителя. Возможно, есть какая-то логика, которая гласит: «У нас есть старый потребитель, присоединенный к этой теме, поэтому вы не можете отправлять заголовки»

ользую эту настройку docker-compose для локальной настройки Kafka: https://github.com/wurstmeister/kafka-docker/ [https://github.com/wurstmeister/kafka-docker/] docker-compose up работает отлично, создание тем через оболочку ...

1 ответ

Кроме того, если вы создаете темы заранее или запускаете производителя раньше потребителя, такое поведение не должно происходить вообще.

2 ответа

Я думаю, что вы можете использовать что-то вроде этого:

ли способ сделать операцию, подобную ветви, но поместить запись в каждый выходной поток, предикат которого оценивается как true? Brach помещает запись в первое совпадение (документация: запись помещается в один и только один выходной поток при ...

1 ответ

Не стесняйтесь принять мой ответ, если он работает сейчас :)

даю данные обработки KTable из KStream. Но когда я запускаю сообщения-захоронения с ключом и нулевой полезной нагрузкой, это не удаляет сообщение из KTable. образец - public KStream<String, GenericRecord> ...

2 ответа

Чтение того же сообщения несколько раз от Кафки

2 ответа

Спасибо, Гэри. Ты спас мой день :)

работал@KafkaListener это также отмеченоConsumerAwareRebalanceListener интерфейс, используя Spring Boot 2.0.6. Я реализовалonPartitionsAssigned метод, в котором я перематываю смещение на фиксированное количество времени, скажем, 60 секунд. Все ...