我使用合流-3.2.1作为卡夫卡流光器。我正在尝试将我的KGroupedStream<String, MyClass1>聚合到KTable<Windowed<String>,MsgAggr>中。在使用聚合时,我也使用TimeWindows.of(TimeUnit.SECONDS.toMillis(5))。我使用用户定义的"Serdes“作为聚合的参数。用户定义"Serdes“的代码是,
Map<String, Object> serdeProps = new HashMap<>();
final Serializer
当我尝试在kafka主题中使用字符串作为键时,我得到了以下错误。
18/05/14 17:08:26 ERROR async.DefaultEventHandler: Error serializing message for topic my_topic
java.lang.ClassCastException: java.lang.String cannot be cast to [B
at kafka.serializer.DefaultEncoder.toBytes(Encoder.scala:34)
at kafka.producer.async.DefaultEve
我有一个KStream,它从kafka (2.3.0)主题中读取json消息。因为我不能保证,所有这些消息都是有效的json消息,结果是JsonParseExceptions,这让我的程序崩溃,似乎,它们是无法管理的卡夫卡。
我已经创建了以下源代码,它可以很好地处理有效消息,然后被解析为JsonNodes。
final StreamsBuilder builder = new StreamsBuilder();
final Serde<JsonNode> jsonSerde = Serdes.serdeFrom( new JsonSerializer(), new
我试图使在通过exec:java Maven插件运行时工作。
当我将应用程序打包到fatjar中并使用java -jar fat.jar -conf config.json -Dvertx.metrics.options.enabled=true运行时,所有这些都可以正常工作。
当我使用mvn clean package exec:java -DskipTests运行它时,我看到:2016-03-22 18:39:58.833 WARN i.v.c.i.VertxImpl:348 - Metrics has been set to enabled but no VertxMetricsFac
在搜索dns条目(?)时,我遇到了超过4秒的异常线程阻塞。初始化kafka producer时,异常: 2019-02-11 10:00:33,982 WARN [vertx-blocked-thread-checker] io.vertx.core.impl.BlockedThreadChecker - Thread Thread[vert.x-eventloop-thread-0,5,main] has been blocked for 4172 ms, time limit is 1000 ms
io.vertx.core.VertxException: Thread blocked
问题:
请阅读以上链接,谢谢!
当我使用spring-boot和spring-kafka时,我的代码如下:
# application.properties
spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=mock-test
spring.kafka.consumer.key- deserializer=org.apache.kafka.common.serialization.StringDeserializer
# HERE: how should I set value serial
我正在尝试用JUnit4实现一个参数化的vertx测试。
使用以下代码时:
@RunWith(Parameterized.class)
@Parameterized.UseParametersRunnerFactory(
VertxUnitRunnerWithParametersFactory.class)
public class RouteTest {
/**
* @return the test routes
*/
@Parameters
public static Iterable<String> routes() {
return Arrays.asLis
我有一个Kafka消费者应用程序,用Spring 2.0.2编写。当我在侦听器中收到消息时,会收到以下错误:
Caused by: org.springframework.messaging.converter.MessageConversionException: failed to resolve class name. Class not found [com.test.demo.domain.Account]; nested exception is java.lang.ClassNotFoundException: com.test.demo.domain.Account
生产者中对