@@ -91,8 +91,7 @@ private static Properties getConsumerProperties(String bootstrapServers) {
9191 final Properties consumerProperties = new Properties ();
9292
9393 consumerProperties .put (
94- ConsumerConfig .INTERCEPTOR_CLASSES_CONFIG ,
95- SentryKafkaConsumerInterceptor .class .getName ());
94+ ConsumerConfig .INTERCEPTOR_CLASSES_CONFIG , SentryKafkaConsumerInterceptor .class .getName ());
9695
9796 consumerProperties .put (ConsumerConfig .BOOTSTRAP_SERVERS_CONFIG , bootstrapServers );
9897 consumerProperties .put (
@@ -101,8 +100,7 @@ private static Properties getConsumerProperties(String bootstrapServers) {
101100 consumerProperties .put (
102101 ConsumerConfig .KEY_DESERIALIZER_CLASS_CONFIG , StringDeserializer .class .getName ());
103102 consumerProperties .put (
104- ConsumerConfig .VALUE_DESERIALIZER_CLASS_CONFIG ,
105- StringDeserializer .class .getName ());
103+ ConsumerConfig .VALUE_DESERIALIZER_CLASS_CONFIG , StringDeserializer .class .getName ());
106104 consumerProperties .put (ConsumerConfig .DEFAULT_API_TIMEOUT_MS_CONFIG , 2000 );
107105 consumerProperties .put (ConsumerConfig .REQUEST_TIMEOUT_MS_CONFIG , 2000 );
108106
@@ -113,13 +111,13 @@ private static Properties getProducerProperties(String bootstrapServers) {
113111 final Properties producerProperties = new Properties ();
114112
115113 producerProperties .put (
116- ProducerConfig .INTERCEPTOR_CLASSES_CONFIG , SentryKafkaProducerInterceptor .class .getName ());
114+ ProducerConfig .INTERCEPTOR_CLASSES_CONFIG , SentryKafkaProducerInterceptor .class .getName ());
117115
118116 producerProperties .put (ProducerConfig .BOOTSTRAP_SERVERS_CONFIG , bootstrapServers );
119117 producerProperties .put (
120- ProducerConfig .KEY_SERIALIZER_CLASS_CONFIG , StringSerializer .class .getName ());
118+ ProducerConfig .KEY_SERIALIZER_CLASS_CONFIG , StringSerializer .class .getName ());
121119 producerProperties .put (
122- ProducerConfig .VALUE_SERIALIZER_CLASS_CONFIG , StringSerializer .class .getName ());
120+ ProducerConfig .VALUE_SERIALIZER_CLASS_CONFIG , StringSerializer .class .getName ());
123121 producerProperties .put (ProducerConfig .MAX_BLOCK_MS_CONFIG , 2000 );
124122 producerProperties .put (ProducerConfig .REQUEST_TIMEOUT_MS_CONFIG , 2000 );
125123 producerProperties .put (ProducerConfig .DELIVERY_TIMEOUT_MS_CONFIG , 3000 );
0 commit comments