clear query| facets| time Search criteria: .   Results from 1 to 10 from 70 (0.0s).
Loading phrases to help you
refine your search...
[KAFKA-9033] Change default client-id in consumer / producer to be more meaningful - Kafka - [issue]
...Right now in consumer / producer, the default client-id is set as consumer-[suffix] and producer-[suffix] which is not very meaningful; on the other hand, since client-ids wi...    Author: Guozhang Wang , 2019-10-15, 21:53
[KAFKA-9014] AssertionError thrown by SourceRecordWriteCounter when SourceTask.poll returns an empty list - Kafka - [issue]
...When creating a custom SourceConnectorTask where the implementation of `poll()` returns an empty List, the connector crashes with an AssertionError....    Author: Richard Wise , 2019-10-15, 21:51
[KAFKA-8370] Kafka Connect should check for existence of internal topics before attempting to create them - Kafka - [issue]
...The Connect worker doesn't current check for the existence of the internal topics, and instead is issuing a CreateTopic request and handling a TopicExistsException. However, this can cause p...    Author: Randall Hauch , 2019-10-15, 21:41
[KAFKA-8125] Check for topic existence in CreateTopicsRequest prior to creating replica assignment - Kafka - [issue]
...Imagine the following pattern to ensure topic creation in an application: Attempt to create a topic with # partitions P and replication factor R.  If topic creation fails with TopicExistsExc...    Author: Lucas Bradstreet , 2019-10-15, 21:34
[KAFKA-9030] Document Instance-level Metrics - Kafka - [issue]
...Document instance-level (client-level) metrics....    Author: Bruno Cadonna , 2019-10-15, 21:30
[VOTE] KIP-458: Connector Client Config Override Policy - Kafka - [mail # dev]
...Hi all,I'd like  to bring attention to a feature that was added as part of the KIPbut never actually documented: the new "admin." prefix and how it's used byworkers to compute the confi...
   Author: Chris Egerton , 2019-10-15, 21:18
[KAFKA-9046] Connect worker configs require undocumented 'admin.' prefix to configure DLQ for connectors - Kafka - [issue]
...The changes for KAFKA-8265 involved adding a prefix of "admin." to Connect worker configs that would be used to configure the admin client that's used for connector DLQs. However, this was n...    Author: Chris Egerton , 2019-10-15, 21:14
[expand - 1 more] - Resetting idleStartTime when all partitions are empty - Kafka - [mail # user]
...Hi Matthias,In our case, we are doing a Left-Join between a KStream and a KTable. Thedata can arrive with a few milliseconds/seconds apart. If the KTablearrives first, that's fine. However, ...
   Author: Javier Holguera , Matthias J. Sax , ... , 2019-10-15, 20:17
[KAFKA-8025] Flaky Test RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest#shouldForwardAllDbOptionsCalls - Kafka - [issue]
...At least one occurence where the following unit test case failed on a jenkins job that didn't involve any related changes.    Author: Konstantine Karantasis , 2019-10-15, 20:09
[KAFKA-9041] Flaky Test LogCleanerIntegrationTest#testIsThreadFailed - Kafka - [issue]
... expected:<1> but was:<0...    Author: Matthias J. Sax , 2019-10-15, 20:08