Skip to content

Commit

Permalink
Test consumer
Browse files Browse the repository at this point in the history
  • Loading branch information
torchr89 committed Oct 23, 2023
1 parent 32bebff commit 35445a6
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-v1",
ConsumerConfig.GROUP_ID_CONFIG to "aktivitetskrav-backend-group-test-2",
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 35445a6

Please sign in to comment.