我试图使用Consumed.as()方法命名我的源处理器(下面是完整的代码): .streamPlease specify a value serde or set one through StreamsConfig#DEFAULT_VALUE_SERDE_CLASS_CONFIG但也有同样的错误。val topology: Topology = buil
我正在编写一个基本的应用程序来测试Kafka流的交互式查询功能。<byte[], Integer, KeyValueStore<Bytes, byte[]>>as("test-store").withKeySerde(Serdes.ByteArray()).withValueSerde(Serdes.Integer())
final KafkaStreams streams = new KafkaStreams<