Skip to content
Snippets Groups Projects
Select Git revision
  • master default protected
1 result
You can move around the graph by using the arrow keys.
Created with Raphaël 2.2.04Mar52128Feb272625232221201918171615141312131211121110876542131Jan3029262524232221201918171615141311109876543228Dec212019171413121110986543432330Nov2930292827262322212019161514131210987653131Oct3029282726252423222018171615131211109865432130Sep2928272625242120191817161413121110987543131Aug3029282725242322212018171615141312109876432131Jul2928improve some logging statements (#6078)KAFKA-7312: Change broker port used in testMinimumRequestTimeouts and testForceCloseKAFKA-7997: Use automatic RPC generation in SaslAuthenticateKAFKA-8002; Log dir reassignment stalls if future replica has different segment base offset (#6346)KAFKA-3522: Add TimestampedKeyValueStore builder/runtime classes (#6152)HOTFIX: add igore import to streams_upgrade_testMINOR: ConsumerNetworkClient does not need to send the remaining requests when the node is not ready (#6264)KAFKA-7922: Return authorized operations in describe consumer group responses (KIP-430 Part-1)KAFKA-7918: Inline generic parameters Pt. III: in-memory window store (#6328)KAFKA-8012; Ensure partitionStates have not been removed before truncating. (#6333)KAFKA-8011: Fix for race condition causing concurrent modification exception (#6338)KAFKA-7912: Support concurrent access in InMemoryKeyValueStore (#6336)MINOR: Skip quota check when replica is in sync (#6344)HOTFIX: Change header back to http instead of https to path license header test (#6347)MINOR: fix release.py script (#6317)MINOR: Remove types from caching stores (#6331)MINOR: Improve logging for alter log dirs (#6302)MINOR: state.cleanup.delay.ms default is 600,000 ms (10 minutes). (#6345)MINOR: disable Streams system test for broker upgrade/downgrade (#6341)KAFKA-7962: Avoid NPE for StickyAssignor (#6308)Address flakiness of CustomQuotaCallbackTest#testCustomQuotaCallback (#6330)KAFKA-7918: Inline generic parameters Pt. II: RocksDB Bytes Store and Memory LRU Caches (#6327)MINOR: fix parameter naming (#6316)KAFKA-7956 In ShutdownableThread, immediately complete the shutdown if the thread has not been started (#6218)MINOR: Refactor replica log dir fetching for improved logging (#6313)[TRIVIAL] Remove unused StreamsGraphNode#repartitionRequired (#6227)MINOR: Increase produce timeout to 120 seconds (#6326)KAFKA-7918: Inline generic parameters Pt. I: in-memory key-value store (#6293)MINOR: Fix line break issue in upgrade notes (#6320)KAFKA-7972: Use automatic RPC generation in SaslHandshakeMINOR: Enable capture of full stack trace in StreamTask#process (#6310)KAFKA-7938: Fix test flakiness in DeleteConsumerGroupsTest (#6312)KAFKA-7937: Fix Flaky Test ResetConsumerGroupOffsetTest.testResetOffsetsNotExistingGroup (#6311)MINOR: Update docs to say 2.2 (#6315) KAFKA-7672 : force write checkpoint during StreamTask #suspend (#6115)KAFKA-7961; Ignore assignment for un-subscribed partitions (#6304)KAFKA-7672: Restoring tasks need to be closed upon task suspension (#6113)KAFKA-7864; validate partitions are 0-based (#6246)KAFKA-7492 : Updated javadocs for aggregate and reduce methods returning null behavior. (#6285)MINOR: Missing punctuation marks in quickstart (#5755)