весенний облачный поток - группа потребителей

Question

Мой потребитель привязан к анонимной группе потребителей вместо указанной мной группы потребителей.

spring:
  cloud:
    stream:
      kafka:
        binder:
          brokers: localhost
          defaultBrokerPort: 9092
          zkNodes: localhost
          defaultZkPort: 2181
        bindings:
          inEvent:
            group: eventin
            destination: event
          outEvent:
            group: eventout
            destination: processevent

Загрузочное приложение My Spring

@SpringBootApplication
@EnableBinding(EventStream.class)
public class ConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
    }
    @StreamListener(value = "inEvent")
    public void getEvent(Event event){
        System.out.println(event.name);
    }
}

Мой интерфейс канала ввода-вывода

public interface EventStream {
    @Input("inEvent")
    SubscribableChannel inEvent();
    @Output("outEvent")
    MessageChannel outEvent();
}

мой консольный журнал -

: запуск приложения ConsumerApplication через 3,233 секунды (JVM работает в течение 4.004): [ Consumer clientId = consumer-3, groupId = anonymous.0d0c87d6-ef39-4bfe-b475-4491c40caf6d] Обнаружен координатор группы singh: 9092 (id: 2147483647 стойка: пусто): [Consumer clientId = consumer-3, groupId = anonymous.0d0c87d6-ef39-4bfe-b475-4491c40caf6d] Отмена ранее назначенной части[]: разделы отменены: []: [Consumer clientId = consumer-3, groupId = anonymous.0d0c87d6-ef39-4bfe-b475-4491c40caf6d] (Re) присоединяющаяся группа: [Consumer clientId = consumer-3, groupId = анонимный.0d0c87d6-ef39-4bfe-b475-4491c40caf6d] Успешно присоединенная группа с поколением 1: [Consumer clientId = consumer-3, groupId = anonymous.0d0c87d6-ef39-4bfe-b475-4491c40caf6d] Установка вновь назначенного partitions [inEvent-0]: [Consumer clientId = consumer-3, groupId = anonymous.0d0c87d6-ef39-4bfe-b475-4491c40caf6d] Сброс смещения для раздела inEvent-0 на смещение 2.: назначенные разделы: [inEvent-0]

Answer 1

Свойство group не должно находиться в дереве kafka.Это должно быть так:

Мой потребитель привязан к анонимной группе потребителей вместо указанной мной группы потребителей.

spring:
  cloud:
    stream:
       bindings:
          inEvent:
            group: eventin
            destination: event

См. Дополнительную информацию в Документах: http://cloud.spring.io/spring-cloud-static/spring-cloud-stream/2.1.1.RELEASE/single/spring-cloud-stream.html#consumer-groups

group является общим свойством, поэтому оно независимо от реализации связующего.kafka предназначен для специфических свойств Apache Kafka, доступных на уровне реализации связующего.