Page History

finalKafkaProducer varkafkaProducer consumerBuilder = new ConsumerBuilder<StringProducerBuilder<String, MyPojo>(<MAP_OR_PROPERTIES_OR_CONFIG>)
  .withKeyDeserializerwithKeySerializer(<KEY_DESERIALIZER>SERIALIZER>)
  .withValueDeserializerwithValueSerializer(<VALUE_DESERIALIZER>SERIALIZER>)
  .withInterceptors(<LIST_OF_INTERCEPTORS>)
  .withPartitioner(<PARTITIONER>)
  .withMetricsReporter(<METRICS_REPORTER>)
  .build();  

finalKafkaConsumer var producerBuilderconsumer = new ProducerBuilder<StringConsumerBuilder<String, MyPojo>(<MAP_OR_PROPERTIES_OR_CONFIG>)
  .withKeySerializerwithKeyDeserializer(<KEY_SERIALIZER>DESERIALIZER>)
  .withValueSerializerwithValueDeserializer(<VALUE_SERIALIZER>DESERIALIZER>)
  .withInterceptors(<LIST_OF_INTERCEPTORS>)
  .withPartitioner(<PARTITIONER>)
  .withMetricsReporter(<METRICS_REPORTER>)
  .build();

finalKafkaStreams var kafkaStreamsBuilderkafkaStreams = new KafkaStreamsBuilder(<TOPOLOGY>, <MAP_OR_PROPERTIES_OR_CONFIG>)
  .withProducerInterceptors(<LIST_OF_PRODUER_INTERCEPTORS>)
  .withConsumerInterceptors(<LIST_OF_CONSUMER_INTERCEPTORS>)
  .withTime(<TIME>)
  .withKafkaClientSupplier(<KAFKA_CLIENT_SUPPLIER>)
  .withMetricsReporter(<METRICS_REPORTER>)
  .build();