clear query| facets| time Search criteria: .   Results from 1 to 7 from 7 (0.0s).
Loading phrases to help you
refine your search...
[KAFKA-6551] Unbounded queues in WorkerSourceTask cause OutOfMemoryError - Kafka - [issue]
...A Debezium user reported an OutOfMemoryError to us, with over 50,000 messages in the WorkerSourceTask#outstandingMessages map.This map is unbounded and I can't see any way of "rate limiting"...
http://issues.apache.org/jira/browse/KAFKA-6551    Author: Gunnar Morling , 2018-09-21, 18:23
[KAFKA-7336] Kafka Connect source task hangs when producing record with invalid topic name - Kafka - [issue]
...If a Kafka Connect source task returns a SourceRecord with an invalid topic name (e.g. "dbserver1.inventory.test@data"), that source task hangs (presumably indefinitely?) and doesn't continu...
http://issues.apache.org/jira/browse/KAFKA-7336    Author: Gunnar Morling , 2018-08-24, 08:53
[KAFKA-7058] ConnectSchema#equals() broken for array-typed default values - Kafka - [issue]
...ConnectSchema#equals() calls Objects#equals() for the schemas' default values, but this doesn't work correctly if the default values in fact are arrays. In this case, always false will be re...
http://issues.apache.org/jira/browse/KAFKA-7058    Author: Gunnar Morling , 2018-06-17, 06:28
[KAFKA-6566] SourceTask#stop() not called after exception raised in poll() - Kafka - [issue]
...Having discussed this with Randall Hauch, it has been my assumption that SourceTask#stop() will be called by the Kafka Connect framework in case an exception has been raised in poll(). That'...
http://issues.apache.org/jira/browse/KAFKA-6566    Author: Gunnar Morling , 2018-05-18, 17:46
Exposing additional metadata in Kafka Connect schema parameters - Kafka - [mail # dev]
...Hi,A user of the Debezium CDC Kafka Connect connectors has asked whether wecould provide information about the original source type of captured tablecolumns.Usually the type info we provide ...
   Author: Gunnar Morling , 2018-03-06, 11:29
[KAFKA-6456] Improve JavaDoc of SourceTask#poll() to discourage indefinite blocking - Kafka - [issue]
...The docs of poll() currently say "This method should block if no data is currently available". This causes the task from transitioning to PAUSED state, if there's no data available for a lon...
http://issues.apache.org/jira/browse/KAFKA-6456    Author: Gunnar Morling , 2018-01-18, 17:57
KIP-199 - Could offset management be part of the Connect REST API? - Kafka - [mail # dev]
...Hi,I was reading KIP-199 [1] for adding a tool for Kafka Connect offsetmanagement. This would be a very useful functionality for users of theDebezium CDC connectors, too.What I was wondering...
   Author: Gunnar Morling , 2017-11-17, 20:32