Skip to content

Instantly share code, notes, and snippets.

View krasowskir's full-sized avatar

Virtuos krasowskir

View GitHub Profile
package servicetests
import com.example.kafkaFirstConsumer.DemoApplication
import com.example.kafkaFirstConsumer.service.MyAckConsumer
import org.apache.kafka.clients.consumer.Consumer
import org.apache.kafka.clients.consumer.ConsumerConfig
import org.apache.kafka.clients.producer.ProducerConfig
import org.apache.kafka.clients.producer.ProducerRecord
import org.apache.kafka.common.TopicPartition
import org.apache.kafka.common.serialization.StringDeserializer