implement the function pointer type PartitionerConstructor func(topic string) Partitioner

Setup is run at the beginning of a new session, before ConsumeClaim

Called once for each message produced to indicate delivery result. Triggered by poll() or flush().

* @brief Message delivery report callback. * * This callback is called exactly once per message, indicating if * the message was succesfully delive

* @brief Message delivery report callback. * * This callback is called exactly once per message, indicating if * the message was succesfully delive

配置监听，将消费工厂信息配置进去

配置监听，将消费工厂信息配置进去

配置监听，将消费工厂信息配置进去

* Kafka logger callback (optional) */

* Kafka logger callback (optional) */

The Streams application as a whole can be launched like any normal Java application that has a `main()` method.