clear query| facets| time Search criteria: .   Results from 1 to 10 from 625 (0.0s).
Loading phrases to help you
refine your search...
[KAFKA-7316] Use of filter method in KTable.scala may result in StackOverflowError - Kafka - [issue]
...In this thread: reported seeing StackOverflowError when using filter method from KTable.scalaThis can be re...    Author: Ted Yu , 2018-10-19, 18:18
[KAFKA-5846] Use singleton NoOpConsumerRebalanceListener in subscribe() call where listener is not specified - Kafka - [issue]
...Currently KafkaConsumer creates instance of NoOpConsumerRebalanceListener for each subscribe() call where ConsumerRebalanceListener is not specified:    public void subscribe(Patte...    Author: Ted Yu , 2018-10-17, 09:12
[DISCUSS] Replacing EasyMock with Mockito in Kafka - Kafka - [mail # dev]
...+1 to moving to MockitoOn Fri, Oct 5, 2018 at 12:11 PM Ron Dagostino  wrote:> I have used Mockito and am a big fan -- I had never used EasyMock until> recently.  The concept ...
   Author: Ted Yu , 2018-10-05, 19:25
[KAFKA-6303] Potential lack of synchronization in NioEchoServer#AcceptorThread - Kafka - [issue]
...In the run() method:                                SocketChannel socketChannel = ((ServerSocketChannel) key.c...    Author: Ted Yu , 2018-10-01, 22:42
[KAFKA-7276] Consider using re2j to speed up regex operations - Kafka - [issue]
... claims to do linear time regular expression matching in Java.Its benefit is most obvious for deeply nested regex (such as a | b | c | d).We should consider...    Author: Ted Yu , 2018-10-01, 22:42
[KAFKA-5863] Potential null dereference in DistributedHerder#reconfigureConnector() - Kafka - [issue]
...Here is the call chain:                                RestServer.httpRequest(reconfigUrl, "POST", taskProps, ...    Author: Ted Yu , 2018-09-25, 03:38
[KAFKA-6904] DynamicBrokerReconfigurationTest#testAdvertisedListenerUpdate is flaky - Kafka - [issue]
...From :kafka.server.DynamicBrokerReconf...    Author: Ted Yu , 2018-09-22, 19:06
[KAFKA-7175] Make version checking logic more flexible in - Kafka - [issue]
...During debugging of system test failure for KAFKA-5037, it was re-discovered that the version numbers inside version probing related messages are hard coded in streams_upgrade_test.pyThis is...    Author: Ted Yu , 2018-09-16, 18:15
[KAFKA-7344] Return early when all tasks are assigned in StickyTaskAssignor#assignActive - Kafka - [issue]
...After re-assigning existing active tasks to clients that previously had the same active task, there is chance that taskIds.size() == assigned.size(), i.e. all tasks are assigned .The method ...    Author: Ted Yu , 2018-09-16, 18:12
[KAFKA-7334] Suggest changing config for state.dir in case of FileNotFoundException - Kafka - [issue]
...Quoting stack trace from KAFKA-5998 :WARN [2018-08-22 03:17:03,745] org.apache.kafka.streams.processor.internals.ProcessorStateManager: task [0_45] Failed to write offset checkpoint file to ...    Author: Ted Yu , 2018-08-30, 01:43