This is an automated email from the ASF dual-hosted git repository. riemer pushed a commit to branch fix-kafka-auto-offset in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 3f871dda86c61bf55aeb9216541975c04cfd196a Author: Dominik Riemer <[email protected]> AuthorDate: Wed Jun 28 08:42:36 2023 +0200 [hotfix] Use latest offset setting as kafka consumer default --- .../streampipes/messaging/kafka/config/ConsumerConfigFactory.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/config/ConsumerConfigFactory.java b/streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/config/ConsumerConfigFactory.java index 4019cd7ba..3ab75d03e 100644 --- a/streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/config/ConsumerConfigFactory.java +++ b/streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/config/ConsumerConfigFactory.java @@ -33,7 +33,7 @@ public class ConsumerConfigFactory extends AbstractConfigFactory { private static final Integer FETCH_MAX_BYTES_CONFIG_DEFAULT = 52428800; private static final String KEY_DESERIALIZER_CLASS_CONFIG_DEFAULT = ByteArrayDeserializer.class.getName(); private static final String VALUE_DESERIALIZER_CLASS_CONFIG_DEFAULT = ByteArrayDeserializer.class.getName(); - private static final String AUTO_OFFSET_RESET_CONFIG_DEFAULT = "earliest"; + private static final String AUTO_OFFSET_RESET_CONFIG_DEFAULT = "latest"; public ConsumerConfigFactory(KafkaTransportProtocol protocol) { super(protocol);
