File tree 1 file changed +2
-2
lines changed
src/integrationTest/java/com/mongodb/kafka/connect 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -52,7 +52,7 @@ void testASimpleProducerSmokeTest() {
52
52
props .put (ProducerConfig .ACKS_CONFIG , "all" );
53
53
props .put (ProducerConfig .ENABLE_IDEMPOTENCE_CONFIG , "true" );
54
54
55
- try (KafkaProducer <Integer , String > producer = new KafkaProducer <>(props )) {
55
+ try (KafkaProducer <Integer , String > producer = new KafkaProducer <>(props )) {
56
56
producer .initTransactions ();
57
57
producer .beginTransaction ();
58
58
@@ -86,7 +86,7 @@ void testSinkSavesAvroDataToMongoDB() {
86
86
producerProps .put (ProducerConfig .VALUE_SERIALIZER_CLASS_CONFIG , "io.confluent.kafka.serializers.KafkaAvroSerializer" );
87
87
producerProps .put (KafkaAvroSerializerConfig .SCHEMA_REGISTRY_URL_CONFIG , KAFKA .schemaRegistryUrl ());
88
88
89
- try (KafkaProducer <String , TweetMsg > producer = new KafkaProducer <>(producerProps )) {
89
+ try (KafkaProducer <String , TweetMsg > producer = new KafkaProducer <>(producerProps )) {
90
90
producer .initTransactions ();
91
91
producer .beginTransaction ();
92
92
tweets .forEach (tweet -> producer .send (new ProducerRecord <>(topicName , tweet )));
You can’t perform that action at this time.
0 commit comments