File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed 
src/integrationTest/java/com/mongodb/kafka/connect Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -52,7 +52,7 @@ void testASimpleProducerSmokeTest() {
5252        props .put (ProducerConfig .ACKS_CONFIG , "all" );
5353        props .put (ProducerConfig .ENABLE_IDEMPOTENCE_CONFIG , "true" );
5454
55-         try (KafkaProducer <Integer , String > producer  = new  KafkaProducer <>(props )) {
55+         try   (KafkaProducer <Integer , String > producer  = new  KafkaProducer <>(props )) {
5656            producer .initTransactions ();
5757            producer .beginTransaction ();
5858
@@ -86,7 +86,7 @@ void testSinkSavesAvroDataToMongoDB() {
8686        producerProps .put (ProducerConfig .VALUE_SERIALIZER_CLASS_CONFIG , "io.confluent.kafka.serializers.KafkaAvroSerializer" );
8787        producerProps .put (KafkaAvroSerializerConfig .SCHEMA_REGISTRY_URL_CONFIG , KAFKA .schemaRegistryUrl ());
8888
89-         try (KafkaProducer <String , TweetMsg > producer  = new  KafkaProducer <>(producerProps )) {
89+         try   (KafkaProducer <String , TweetMsg > producer  = new  KafkaProducer <>(producerProps )) {
9090            producer .initTransactions ();
9191            producer .beginTransaction ();
9292            tweets .forEach (tweet  -> producer .send (new  ProducerRecord <>(topicName , tweet )));
    
 
   
 
     
   
   
          
     
  
    
     
 
    
      
     
 
     
    You can’t perform that action at this time.
  
 
    
  
     
    
      
        
     
 
       
      
     
   
 
    
    
  
 
  
 
     
    
0 commit comments