MCPcopy Create free account

hub / github.com/bjpublic/apache-kafka-with-java / types & classes

Types & classes65 in github.com/bjpublic/apache-kafka-with-java

⨍ Functions 138◇ Types & classes 65
ClassConsumerWithASyncCommit
Chapter3/3.4.2 kafka-consumer/kafka-consumer-async-commit/src/main/java/com/example/ConsumerWithASyncCommit.java:14
ClassConsumerWithAutoCommit
Chapter3/3.4.2 kafka-consumer/kafka-consumer-auto-commit/src/main/java/com/example/ConsumerWithAutoCommit.java:15
ClassConsumerWithExactPartition
Chapter3/3.4.2 kafka-consumer/kafka-consumer-exact-partition/src/main/java/com/example/ConsumerWithExactPartition.java:13
ClassConsumerWithMultiWorkerThread
Chapter4/4.3 kafka-consumer/kafka-consumer-with-multi-worker-thread/src/main/java/com/example/ConsumerWithMultiWorkerThread.java:17
ClassConsumerWithRebalanceListener
Chapter3/3.4.2 kafka-consumer/kafka-consumer-rebalance-listener/src/main/java/com/example/ConsumerWithRebalanceListener.java:11
ClassConsumerWithSyncCommit
Chapter3/3.4.2 kafka-consumer/kafka-consumer-sync-commit/src/main/java/com/example/ConsumerWithSyncCommit.java:12
ClassConsumerWithSyncOffsetCommit
Chapter3/3.4.2 kafka-consumer/kafka-consumer-sync-offset-commit/src/main/java/com/example/ConsumerWithSyncOffsetCommit.java:15
ClassConsumerWithSyncOffsetCommit
Chapter3/3.4.2 kafka-consumer/kafka-consumer-sync-offset-commit-shutdown-hook/src/main/java/com/example/ConsumerWithSyncOffsetCommit.java:14
ClassConsumerWorker
Chapter5/5.1 web-page-event-pipeline/kafka-multi-consumer-thread-hdfs-save/src/main/java/com/pipeline/consumer/ConsumerWorker.java:18
ClassConsumerWorker
Chapter4/4.3 kafka-consumer/kafka-multi-consumer-thread-by-partition/src/main/java/com/example/ConsumerWorker.java:14
ClassConsumerWorker
Chapter4/4.3 kafka-consumer/kafka-consumer-with-multi-worker-thread/src/main/java/com/example/ConsumerWorker.java:6
ClassConsumerWorker
Chapter4/4.3 kafka-consumer/kafka-multi-consumer-thread/src/main/java/com/example/ConsumerWorker.java:13
ClassCustomPartitioner
Chapter3/3.4.1 kafka-producer/kafka-producer-custom-partitioner/src/main/java/com/example/CustomPartitioner.java:12
ClassElasticSearchSinkConnector
Chapter5/5.1 web-page-event-pipeline/elasticsearch-kafka-connector/src/main/java/com/pipeline/ElasticSearchSinkConnector.java:17
ClassElasticSearchSinkConnectorConfig
Chapter5/5.1 web-page-event-pipeline/elasticsearch-kafka-connector/src/main/java/com/pipeline/config/ElasticSearchSinkConnectorConfig.java:9
ClassElasticSearchSinkTask
Chapter5/5.1 web-page-event-pipeline/elasticsearch-kafka-connector/src/main/java/com/pipeline/ElasticSearchSinkTask.java:27
ClassFilterProcessor
Chapter3/3.5 kafka-streams/simple-kafka-processor/src/main/java/com/example/FilterProcessor.java:7
ClassHdfsSinkApplication
Chapter5/5.1 web-page-event-pipeline/kafka-multi-consumer-thread-hdfs-save/src/main/java/com/pipeline/HdfsSinkApplication.java:14
ClassIdempotenceProducer
Chapter4/4.2.2 idempotence-producer/src/main/java/com/example/IdempotenceProducer.java:12
ClassKStreamCountApplication
Chapter3/3.5 kafka-streams/kstream-count/src/main/java/com/example/KStreamCountApplication.java:14
ClassKStreamJoinGlobalKTable
Chapter3/3.5 kafka-streams/kstream-globalktable-join/src/main/java/com/example/KStreamJoinGlobalKTable.java:12
ClassKStreamJoinKTable
Chapter3/3.5 kafka-streams/kstream-ktable-join/src/main/java/com/example/KStreamJoinKTable.java:12
ClassKafkaAdminClient
Chapter3/3.4.3 kafka-admin/kafka-admin-client/src/main/java/com/example/KafkaAdminClient.java:15
ClassKafkaTemplateConfiguration
Chapter4/4.4 spring-kafka/spring-kafka-template-producer/src/main/java/com/example/KafkaTemplateConfiguration.java:11
ClassListenerContainerConfiguration
Chapter4/4.4 spring-kafka/spring-kafka-listener-container/src/main/java/com/example/ListenerContainerConfiguration.java:18
ClassMetricJsonUtils
Chapter5/5.2 metric-log-pipeline-streams/metric-kafka-streams/src/main/java/com/pipeline/MetricJsonUtils.java:6
ClassMetricStreams
Chapter5/5.2 metric-log-pipeline-streams/metric-kafka-streams/src/main/java/com/pipeline/MetricStreams.java:10
ClassMultiConsumerThread
Chapter4/4.3 kafka-consumer/kafka-multi-consumer-thread/src/main/java/com/example/MultiConsumerThread.java:10
ClassMultiConsumerThreadByPartition
Chapter4/4.3 kafka-consumer/kafka-multi-consumer-thread-by-partition/src/main/java/com/example/MultiConsumerThreadByPartition.java:18
ClassProduceController
Chapter5/5.1 web-page-event-pipeline/kafka-spring-producer-with-rest-controller/src/main/java/com/pipeline/ProduceController.java:15
ClassProducerCallback
Chapter3/3.4.1 kafka-producer/kafka-producer-async-callback/src/main/java/com/example/ProducerCallback.java:8
ClassProducerExactPartition
Chapter3/3.4.1 kafka-producer/kafka-producer-exact-partition/src/main/java/com/example/ProducerExactPartition.java:9
ClassProducerWithAsyncCallback
Chapter3/3.4.1 kafka-producer/kafka-producer-async-callback/src/main/java/com/example/ProducerWithAsyncCallback.java:9
ClassProducerWithCustomPartitioner
Chapter3/3.4.1 kafka-producer/kafka-producer-custom-partitioner/src/main/java/com/example/ProducerWithCustomPartitioner.java:9
ClassProducerWithKeyValue
Chapter3/3.4.1 kafka-producer/kafka-producer-key-value/src/main/java/com/example/ProducerWithKeyValue.java:9
ClassProducerWithSyncCallback
Chapter3/3.4.1 kafka-producer/kafka-producer-sync-callback/src/main/java/com/example/ProducerWithSyncCallback.java:13
ClassQueryableStore
Chapter3/3.5 kafka-streams/queryable-store/src/main/java/com/example/QueryableStore.java:20
ClassRebalanceListener
Chapter3/3.4.2 kafka-consumer/kafka-consumer-rebalance-listener/src/main/java/com/example/RebalanceListener.java:10
ClassRestApiProducer
Chapter5/5.1 web-page-event-pipeline/kafka-spring-producer-with-rest-controller/src/main/java/com/pipeline/RestApiProducer.java:6
ClassShutdownThread
Chapter3/3.4.2 kafka-consumer/kafka-consumer-sync-offset-commit-shutdown-hook/src/main/java/com/example/ConsumerWithSyncOffsetCommit.java:50
ClassShutdownThread
Chapter5/5.1 web-page-event-pipeline/kafka-multi-consumer-thread-hdfs-save/src/main/java/com/pipeline/HdfsSinkApplication.java:39
ClassShutdownThread
Chapter5/5.2 metric-log-pipeline-streams/metric-kafka-streams/src/main/java/com/pipeline/MetricStreams.java:43
ClassShutdownThread
Chapter4/4.3 kafka-consumer/kafka-multi-consumer-thread-by-partition/src/main/java/com/example/MultiConsumerThreadByPartition.java:89
ClassSimpleConsumer
Chapter6/6.1 confluent-kafka/confluent-kafka-consumer/src/main/java/com/example/SimpleConsumer.java:18
ClassSimpleConsumer
Chapter3/3.4.2 kafka-consumer/simple-kafka-consumer/src/main/java/com/example/SimpleConsumer.java:15
ClassSimpleKafkaProcessor
Chapter3/3.5 kafka-streams/simple-kafka-processor/src/main/java/com/example/SimpleKafkaProcessor.java:10
ClassSimpleProducer
Chapter6/6.1 confluent-kafka/confluent-kafka-producer/src/main/java/com/example/SimpleProducer.java:13
ClassSimpleProducer
Chapter3/3.4.1 kafka-producer/simple-kafka-producer/src/main/java/com/example/SimpleProducer.java:12
ClassSimpleStreamApplication
Chapter3/3.5 kafka-streams/simple-kafka-streams/src/main/java/com/example/SimpleStreamApplication.java:11
ClassSingleFileSinkConnector
Chapter3/3.6 kafka-connector/simple-sink-connector/src/main/java/com/example/SingleFileSinkConnector.java:14
ClassSingleFileSinkConnectorConfig
Chapter3/3.6 kafka-connector/simple-sink-connector/src/main/java/com/example/SingleFileSinkConnectorConfig.java:9
ClassSingleFileSinkTask
Chapter3/3.6 kafka-connector/simple-sink-connector/src/main/java/com/example/SingleFileSinkTask.java:15
ClassSingleFileSourceConnector
Chapter3/3.6 kafka-connector/simple-source-connector/src/main/java/com/example/SingleFileSourceConnector.java:16
ClassSingleFileSourceConnectorConfig
Chapter3/3.6 kafka-connector/simple-source-connector/src/main/java/com/example/SingleFileSourceConnectorConfig.java:10
ClassSingleFileSourceTask
Chapter3/3.6 kafka-connector/simple-source-connector/src/main/java/com/example/SingleFileSourceTask.java:22
ClassSpringConsumerApplication
Chapter4/4.4 spring-kafka/spring-kafka-commit-listener/src/main/java/com/example/SpringConsumerApplication.java:12
ClassSpringConsumerApplication
Chapter4/4.4 spring-kafka/spring-kafka-listener-container/src/main/java/com/example/SpringConsumerApplication.java:9
ClassSpringConsumerApplication
Chapter4/4.4 spring-kafka/spring-kafka-record-listener/src/main/java/com/example/SpringConsumerApplication.java:12
ClassSpringConsumerApplication
Chapter4/4.4 spring-kafka/spring-kafka-batch-listener/src/main/java/com/example/SpringConsumerApplication.java:12
ClassSpringProducerApplication
Chapter4/4.4 spring-kafka/spring-kafka-template-producer/src/main/java/com/example/SpringProducerApplication.java:14
ClassSpringProducerApplication
Chapter4/4.4 spring-kafka/spring-kafka-producer/src/main/java/com/example/SpringProducerApplication.java:9
ClassStreamsFilter
Chapter3/3.5 kafka-streams/kafka-streams-filter/src/main/java/com/example/StreamsFilter.java:11
ClassTransactionConsumer
Chapter4/4.2.3 transaction-consumer/src/main/java/com/example/TransactionConsumer.java:15
ClassTransactionProducer
Chapter4/4.2.3 transaction-producer/src/main/java/com/example/TransactionProducer.java:12
ClassUserEventVO
Chapter5/5.1 web-page-event-pipeline/kafka-spring-producer-with-rest-controller/src/main/java/com/pipeline/UserEventVO.java:3