/**
* If provided, the listener container for this listener will be added to a bean
* with this value as its name, of type {@code Collection<MessageListenerContainer>}.
* This allows, for example, iteration over the collection to start/stop a subset
* of containers.
* @return the bean name for the group.
*/
已重命名 containerGroup 在1.3/2.0中。 这些版本还提供。。。
/**
* Override the {@code group.id} property for the consumer factory with this value
* for this listener only.
* @return the group id.
* @since 1.3
*/
String groupId() default "";
/**
* When {@link #groupId() groupId} is not provided, use the {@link #id() id} (if
* provided) as the {@code group.id} property for the consumer. Set to false, to use
* the {@code group.id} from the consumer factory.
* @return false to disable.
* @since 1.3
*/
boolean idIsGroup() default true;
1条答案
按热度按时间u3r8eeie1#
请参阅javadocs以了解
group
财产;这与Kafka无关group.id
...已重命名
containerGroup
在1.3/2.0中。这些版本还提供。。。
以前,每个侦听器都需要一个容器工厂/消费者工厂;这些允许您使用一个工厂示例并重写
group.id
.