Skip to content

Commit

Permalink
Rename consumer group
Browse files Browse the repository at this point in the history
  • Loading branch information
torchr89 committed Oct 19, 2023
1 parent 797d3c4 commit 55eb611
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ class AivenKafkaConfig(
aivenKafkaErrorHandler: AivenKafkaErrorHandler
): ConcurrentKafkaListenerContainerFactory<String, String> {
val config = mapOf(
ConsumerConfig.GROUP_ID_CONFIG to "aktivitetskrav-backend-group-test",
ConsumerConfig.GROUP_ID_CONFIG to "aktivitetskrav-backend-group-v1",
ConsumerConfig.AUTO_OFFSET_RESET_CONFIG to kafkaAutoOffsetReset,
ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG to StringDeserializer::class.java,
ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG to StringDeserializer::class.java,
Expand Down

0 comments on commit 55eb611

Please sign in to comment.