[kafka] branch trunk updated: HOTFIX: fix checkstyle error of RocksDBStoreTest and flaky RocksDBTimestampedStoreTest.shouldOpenExistingStoreInRegularMode (#8515)

2020-04-19 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new cfea096 HOTFIX: fix checkstyle error

[kafka] branch trunk updated: MINOR: cleanup RocksDBStore tests (#8510)

2020-04-18 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new 6ea3eed MINOR: cleanup RocksDBStore tests

[kafka] branch trunk updated (00a59b3 -> a0173ec)

2020-04-17 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 00a59b3 MINOR: improve test coverage for dynamic LogConfig(s) (#7616) add a0173ec KAFKA-9881: Convert

[kafka] branch trunk updated: HOTFIX: fix active task process ratio metric recording

2020-04-16 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new a0119aa HOTFIX: fix active task process ratio

[kafka] branch trunk updated (1263576 -> 640be46)

2020-04-15 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 1263576 MINOR: add process(Test)Messages to the README (#8480) add 640be46 HOTFIX: don't close or wipe out

[kafka] branch trunk updated (430e00e -> 37f20c69)

2020-04-13 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 430e00e KAFKA-8436: use automated protocol for AddOffsetsToTxn (#7015) add 37f20c69 HOTFIX: need to cleanup

[kafka] branch trunk updated (371ad14 -> 179be72)

2020-04-09 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 371ad14 KAFKA-9691: Fix NPE by waiting for reassignment request (#8317) add 179be72 KAFKA-9642: Change

[kafka] branch trunk updated: KAFKA-9801: Still trigger rebalance when static member joins in CompletingRebalance phase (#8405)

2020-04-07 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new 94ef25a KAFKA-9801: Still trigger rebalance

[kafka] branch 2.5 updated: KAFKA-9801: Still trigger rebalance when static member joins in CompletingRebalance phase (#8405)

2020-04-07 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.5 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.5 by this push: new 146811a KAFKA-9801: Still trigger rebalance when

[kafka] branch trunk updated (9d96523 -> f185016)

2020-04-06 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 9d96523 MINOR: Fix log cleaner offset range log message (#8435) add f185016 MINOR: Should cleanup the tasks

[kafka] branch trunk updated (712ac52 -> 82dff1d)

2020-04-06 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 712ac52 KAFKA-9793: Expand the try-catch for task commit in HandleAssignment (#8402) add 82dff1d KAFKA-9753

[kafka] branch trunk updated: KAFKA-9793: Expand the try-catch for task commit in HandleAssignment (#8402)

2020-04-05 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new 712ac52 KAFKA-9793: Expand the try-catch

[kafka] branch trunk updated: KAFKA-9784: Add OffsetFetch to group concurrency test (#8383)

2020-04-05 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new 3b8ed0a KAFKA-9784: Add OffsetFetch to group

[kafka] branch trunk updated (46540eb -> 23b4d87)

2020-04-04 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 46540eb KAFKA-9820: validateMessagesAndAssignOffsetsCompressed allocates unused iterator (#8422) add 23b4d87

[kafka] branch trunk updated (6ddbf4d -> 7f640f1)

2020-04-02 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 6ddbf4d KAFKA-9809: Shrink transaction timeout for streams (#8407) add 7f640f1 KAFKA-9776: Downgrade

[kafka] branch trunk updated (dfdb49f -> 6ddbf4d)

2020-04-02 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from dfdb49f KAFKA-9778: Add methods to validate and assert connector configurations in integration tests

[kafka] branch trunk updated (cc59150 -> a2092ec)

2020-04-01 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from cc59150 KAFKA-9748: extend EosIntegrationTest for EOS-beta (#8331) add a2092ec HOTFIX: remove redundant check

[kafka] branch 2.5 updated: KAFKA-9659: Add more log4j when updating static member mappings (#8269)

2020-04-01 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.5 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.5 by this push: new 54eafcd KAFKA-9659: Add more log4j when updating

[kafka] branch 2.5 updated: MINOR: more logs for empty assignment (#8397)

2020-03-31 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.5 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.5 by this push: new 2190ae4 MINOR: more logs for empty assignment

[kafka] branch trunk updated (353aa62 -> c181432)

2020-03-31 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 353aa62 KAFKA-9753: Add active tasks process ratio (#8370) add c181432 MINOR: more logs for empty assignment

[kafka] branch trunk updated (121c769 -> 353aa62)

2020-03-31 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 121c769 MINOR: Fix MockAdminClient to not throw IndexOutOfBoundsException when brokerId is above the known one

[kafka] branch trunk updated (c59835c -> 9d9b59f)

2020-03-26 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from c59835c KAFKA-8470: State change logs should not be in TRACE level (#8320) add 9d9b59f KAFKA-9756: Process

[kafka] branch trunk updated (ee0ef09 -> 08759b2)

2020-03-25 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from ee0ef09 MINOR: Allow topics with `null` leader on MockAdminClient createTopic. (#8345) add 08759b2 MINOR

[kafka] branch 2.1 updated: KAFKA-8319: Make KafkaStreamsTest a non-integration test class (#7382) (#8352)

2020-03-25 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.1 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.1 by this push: new b9dd203 KAFKA-8319: Make KafkaStreamsTest a non

[kafka] branch trunk updated (cc70614 -> 1b36e11)

2020-03-24 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from cc70614 KAFKA-9743: Catch commit offset exception to eventually close dirty tasks (#8327) add 1b36e11 MINOR

[kafka] branch trunk updated: KAFKA-9651: Fix ArithmeticException (รท by 0) in DefaultStreamPartitioner (#8226)

2020-03-23 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new 6cfed8a KAFKA-9651: Fix ArithmeticException

[kafka] branch 2.5 updated: KAFKA-9741: Update ConsumerGroupMetadata before calling onPartitionsRevoked() (#8325)

2020-03-20 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.5 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.5 by this push: new 223bb49 KAFKA-9741: Update ConsumerGroupMetadata

[kafka] branch trunk updated: KAFKA-9741: Update ConsumerGroupMetadata before calling onPartitionsRevoked() (#8325)

2020-03-20 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new 635b5fd KAFKA-9741: Update

[kafka] branch 2.5 updated: KAFKA-9701 (fix): Only check protocol name when generation is valid (#8324)

2020-03-20 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.5 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.5 by this push: new 3ea04ff KAFKA-9701 (fix): Only check protocol name

[kafka] branch trunk updated: KAFKA-9701 (fix): Only check protocol name when generation is valid (#8324)

2020-03-20 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new c75dc5e KAFKA-9701 (fix): Only check protocol

[kafka] branch trunk updated (cbdd0d6 -> c249ea8)

2020-03-20 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from cbdd0d6 KAFKA-6145: Add constrained balanced assignment algorithm (#8262) add c249ea8 KAFKA-9727: cleanup

[kafka] branch trunk updated: KAFKA-9568: enforce rebalance if client endpoint has changed (#8299)

2020-03-18 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new 85c96f5 KAFKA-9568: enforce rebalance if client

[kafka] branch trunk updated: KAFKA-5604: Remove the redundant TODO marker on the Streams side (#8313)

2020-03-18 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new b1999ba KAFKA-5604: Remove the redundant TODO

[kafka] branch 2.5 updated: HOTFIX: do not rely on file modified time in StateDirectoryTest

2020-03-18 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.5 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.5 by this push: new 45e0d07 HOTFIX: do not rely on file modified time

[kafka] branch trunk updated (93f082e -> c0cff61)

2020-03-18 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 93f082e MINOR: Update Scala to 2.12.11 (#8308) add c0cff61 HOTFIX: do not depend on file modified time

[kafka] branch trunk updated (6a88d32 -> f08c9c7)

2020-03-17 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 6a88d32 KAFKA-8803: Remove timestamp check in completeTransitionTo (#8278) add f08c9c7 HOTFIX: fix flaky

[kafka] branch trunk updated (f08c9c7 -> d38e97e)

2020-03-17 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from f08c9c7 HOTFIX: fix flaky StateDirectoryTest.shouldReturnEmptyArrayIfListFilesReturnsNull (#8310) add d38e97e

[kafka] branch 2.5 updated: HOTFIX: StateDirectoryTest should use Set instead of List (#8305)

2020-03-17 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.5 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.5 by this push: new 89a5355 HOTFIX: StateDirectoryTest should use Set

[kafka] branch 2.5 updated: KAFKA-8803: Remove timestamp check in completeTransitionTo (#8278)

2020-03-17 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.5 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.5 by this push: new 9d68b8e KAFKA-8803: Remove timestamp check

[kafka] branch trunk updated (9715625 -> 6a88d32)

2020-03-17 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 9715625 MINOR: double -Xss setting from 2m to 4m in build.gradle (#8264) add 6a88d32 KAFKA-8803: Remove

[kafka] branch trunk updated (1e6d944 -> 6730185)

2020-03-16 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 1e6d944 HOTFIX: StateDirectoryTest should use Set instead of List (#8305) add 6730185 MINOR: cleanup and add

[kafka] branch trunk updated: MINOR: enforce non-negative invariant for checkpointed offsets (#8297)

2020-03-15 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new 045c6c3 MINOR: enforce non-negative invariant

[kafka] branch 2.5 updated: KAFKA-6647: Do note delete the lock file while holding the lock (#8267)

2020-03-14 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.5 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.5 by this push: new f2963c2 KAFKA-6647: Do note delete the lock file

[kafka] branch trunk updated: KAFKA-6647: Do note delete the lock file while holding the lock (#8267)

2020-03-14 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new 605d55d KAFKA-6647: Do note delete the lock

[kafka] branch trunk updated (c1901c0 -> 2d2311d)

2020-03-12 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from c1901c0 KAFKA-9644: Handle non-existent configs in incrementalAlterConfigs APPEND/SUBTRACT add 2d2311d KAFKA

[kafka] branch trunk updated (0c256e1 -> 935aa1a)

2020-03-12 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 0c256e1 KAFKA-9675: Fix bug that prevents RocksDB metrics to be updated (#8256) add 935aa1a KAFKA-9659: Add

[kafka] branch trunk updated (524182d -> b526528)

2020-03-11 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 524182d MINOR: Update Streams IQ JavaDocs to not point to a deprecated method (#8271) add b526528 KAFKA-9701

[kafka-site] branch asf-site updated: Remove KS London; added Austin (#257)

2020-03-11 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/kafka-site.git The following commit(s) were added to refs/heads/asf-site by this push: new 200b9ab Remove KS London; added

[kafka] branch trunk updated (97fc6a5 -> b0fd308)

2020-03-10 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 97fc6a5 KAFKA-9658; Fix user quota removal (#8232) add b0fd308 KAFKA-9344: Override default values inside

[kafka] branch trunk updated (fc9d91a -> 33f6e1a)

2020-03-10 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from fc9d91a KAFKA-9686: MockConsumer#endOffsets should be idempotent (#8255) add 33f6e1a HOTFIX: Task#dirtyClose

[kafka] branch trunk updated (cdd5ef3 -> dcfb641)

2020-03-09 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from cdd5ef3 MINOR: Remove throttling logic from RecordAccumulator (#7195) add dcfb641 KAFKA-9176: Do not update

[kafka] branch trunk updated: MINOR: Break up StreamsPartitionAssignor's gargantuan #assign (#8245)

2020-03-07 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new 4b03d67 MINOR: Break up

[kafka] branch trunk updated: MINOR: Reset `streamTime` on clear (#8250)

2020-03-07 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new f081f3b MINOR: Reset `streamTime` on clear

[kafka] branch trunk updated: KAFKA-9645: Fallback to unsubscribe during Task Migrated (#8220)

2020-03-07 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new fe0b704 KAFKA-9645: Fallback to unsubscribe

[kafka] branch trunk updated (d3c067f -> c67e8bc)

2020-03-06 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from d3c067f MINOR: Check store directory empty to decide whether throw task corrupted exception with EOS (#8180

[kafka] branch trunk updated (ca90a84 -> d3c067f)

2020-03-06 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from ca90a84 KAFKA-9668: Iterating over KafkaStreams.getAllMetadata() results in ConcurrentModificationException (#8233

[kafka] branch trunk updated (6b41993 -> ca90a84)

2020-03-06 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 6b41993 KAFKA-9662: Wait for consumer offset reset in throttle test to avoid losing early messages (#8227

[kafka] branch 2.5 updated: KAFKA-9668: Iterating over KafkaStreams.getAllMetadata() results in ConcurrentModificationException (#8233)

2020-03-06 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.5 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.5 by this push: new e6d0d6e KAFKA-9668: Iterating over

[kafka] branch trunk updated (f35e649 -> 41f9d7a)

2020-03-04 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from f35e649 KAFKA-9632; Fix MockScheduler synchronization for safe use in Log/Partition tests (#8209) add 41f9d7a

[kafka] branch trunk updated (69b670a -> c2ec974)

2020-03-03 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 69b670a KAFKA-8995: delete all topics before recreating (#8208) add c2ec974 KAFKA-9618: Directory deletion

[kafka] branch 2.4 updated: KAFKA-8995: delete all topics before recreating (#8208)

2020-03-02 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.4 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.4 by this push: new 7f740a2 KAFKA-8995: delete all topics before

[kafka] branch 2.5 updated: KAFKA-8995: delete all topics before recreating (#8208)

2020-03-02 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.5 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.5 by this push: new a529892 KAFKA-8995: delete all topics before

[kafka] branch 2.5 updated: KAFKA-8995: delete all topics before recreating (#8208)

2020-03-02 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.5 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.5 by this push: new a529892 KAFKA-8995: delete all topics before

[kafka] branch 2.4 updated: KAFKA-8995: delete all topics before recreating (#8208)

2020-03-02 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.4 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.4 by this push: new 7f740a2 KAFKA-8995: delete all topics before

[kafka] branch trunk updated (d3f9cb5 -> 69b670a)

2020-03-02 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from d3f9cb5 MINOR: Update year in NOTICE (#8207) add 69b670a KAFKA-8995: delete all topics before recreating

[kafka] branch 2.5 updated: MINOR: Port streams broker compatibility fix (#8203)

2020-03-02 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.5 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.5 by this push: new 3f99f9d MINOR: Port streams broker compatibility

[kafka] branch trunk updated: KAFKA-9525: add enforceRebalance method to Consumer API (#8087)

2020-02-29 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new a1f2ece KAFKA-9525: add enforceRebalance method

[kafka] branch trunk updated (ede0730 -> e0551ac)

2020-02-28 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from ede0730 KAFKA-9620: Do not throw in the middle of consumer user callbacks (#8187) add e0551ac KAFKA-9623

[kafka] branch trunk updated (294b629 -> ede0730)

2020-02-28 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 294b629 throttle consumer timeout increase (#8188) add ede0730 KAFKA-9620: Do not throw in the middle

[kafka] branch 2.5 updated: Adapt docs about metrics of Streams according to KIP-444 (#8171)

2020-02-27 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.5 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.5 by this push: new d32f72c Adapt docs about metrics of Streams

[kafka] branch trunk updated (399d18f -> d2c4212)

2020-02-27 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 399d18f HOTFIX: testInitTransactionTimeout should use prepareResponse instead of respond (#8179) add d2c4212

[kafka] branch trunk updated (fb5bd9e -> 399d18f)

2020-02-27 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from fb5bd9e HOTFIX: fix failing test PlaintextAdminIntegrationTest.testElectPreferredLeaders (#8178) add 399d18f

[kafka] branch 2.5 updated: MINOR: Remove tag from metric to measure process-rate on source nodes (#8175)

2020-02-27 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.5 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.5 by this push: new 5413675 MINOR: Remove tag from metric to measure

[kafka] branch trunk updated (39d5534 -> bafdf86)

2020-02-26 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 39d5534 MINOR: Remove tag from metric to measure process-rate on source nodes (#8175) add bafdf86 KAFKA-9607

[kafka] branch trunk updated (a983545 -> 39d5534)

2020-02-26 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from a983545 KAFKA-9610: do not throw illegal state when remaining partitions are not empty (#8169) add 39d5534

[kafka] branch trunk updated (dfef2a3 -> a983545)

2020-02-26 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from dfef2a3 KAFKA-9614: Not initialize topology twice in StreamTask (#8173) add a983545 KAFKA-9610: do not throw

[kafka] branch trunk updated (b9e3fa2 -> dfef2a3)

2020-02-26 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from b9e3fa2 KAFKA-9601: Stop logging raw connector config values (#8165) add dfef2a3 KAFKA-9614: Not initialize

[kafka] branch trunk updated (dd22b3f -> 0dc0b71)

2020-02-25 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from dd22b3f KAFKA-9498; Topic validation during the topic creation triggers unnecessary TopicChange events (#8062

[kafka] branch trunk updated (9064026 -> a28447a)

2020-02-25 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 9064026 KAFKA-8147: Add changelog topic configuration to KTable suppress (#8029) add a28447a MINOR: don't

[kafka] branch 2.4 updated: KAFKA-9599 create unique sensor to record group rebalance (#8159)

2020-02-24 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.4 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.4 by this push: new 44fbd96 KAFKA-9599 create unique sensor to record

[kafka] branch 2.5 updated: KAFKA-9599 create unique sensor to record group rebalance (#8159)

2020-02-24 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.5 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.5 by this push: new 4b39238 KAFKA-9599 create unique sensor to record

[kafka] branch trunk updated (1de9981 -> 384eb16)

2020-02-24 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 1de9981 KAFKA-9581: Remove rebalance exception withholding (#8145) add 384eb16 KAFKA-9599 create unique

[kafka] branch trunk updated (2df7ea5 -> 1de9981)

2020-02-24 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 2df7ea5 KAFKA-9530; Fix flaky test `testDescribeGroupWithShortInitializationTimeout` (#8154) add 1de9981

[kafka] branch trunk updated (2df7ea5 -> 1de9981)

2020-02-24 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 2df7ea5 KAFKA-9530; Fix flaky test `testDescribeGroupWithShortInitializationTimeout` (#8154) add 1de9981

[kafka] branch trunk updated (84c4025 -> 003dce5)

2020-02-21 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 84c4025 KAFKA-9206; Throw KafkaException on CORRUPT_MESSAGE error in Fetch response (#8111) add 003dce5

[kafka] branch 2.5 updated: MINOR: Improve EOS example exception handling (#8052)

2020-02-21 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.5 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.5 by this push: new e2f9f08 MINOR: Improve EOS example exception

[kafka] branch 2.5 updated: KAFKA-9582: Do not abort transaction in unclean close (#8143)

2020-02-21 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.5 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.5 by this push: new 121df46 KAFKA-9582: Do not abort transaction

[kafka] branch trunk updated (0d16c26 -> 3b6573c)

2020-02-20 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 0d16c26 HOTFIX: don't try to remove uninitialized changelogs from assignment & don't prematurely mark task cl

[kafka] branch 2.5 updated: KAFKA-9562: part 1: ignore exceptions while flushing stores in close(dirty) (#8116)

2020-02-20 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.5 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.5 by this push: new c3da9ac KAFKA-9562: part 1: ignore exceptions while

[kafka] branch trunk updated (b2aec94 -> 0d16c26)

2020-02-20 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from b2aec94 MINOR: Fix javadoc at org.apache.kafka.clients.producer.KafkaProducer.InterceptorCallback#onCompletion

[kafka] branch trunk updated (776565f -> b2aec94)

2020-02-20 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 776565f MINOR: Improve EOS example exception handling (#8052) add b2aec94 MINOR: Fix javadoc

[kafka] branch 2.5 updated: MINOR: fix omitted 'next.' in interactive queries documentation (#7883)

2020-02-19 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.5 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.5 by this push: new 63a297f MINOR: fix omitted 'next.' in interactive

[kafka] branch trunk updated (5a19fe6 -> 9942e20)

2020-02-19 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 5a19fe6 KAFKA-9544; Fix flaky test `AdminClientTest.testDefaultApiTimeoutOverride` (#8101) add 9942e20 MINOR

[kafka-site] branch asf-site updated: MINOR: fix omitted 'next.' in interactive queries documentation (#247)

2020-02-19 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/kafka-site.git The following commit(s) were added to refs/heads/asf-site by this push: new e5389b6 MINOR: fix omitted 'next

[kafka] branch trunk updated (72122fc -> 913c619)

2020-02-18 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 72122fc KAFKA-6266: Repeated occurrence of WARN Resetting first dirty offset (#8089) add 913c619 MINOR

[kafka] branch 2.5 updated: MINOR: Reduce log level to Trace for fetch offset downgrade (#8093)

2020-02-18 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.5 in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/2.5 by this push: new fd68649 MINOR: Reduce log level to Trace for fetch

[kafka] branch trunk updated (863b534 -> 97c5dc1)

2020-02-16 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 863b534 KAFKA-9535; Update metadata before retrying partitions when fetching offsets (#8088) add 97c5dc1

[kafka] branch trunk updated (16ee326 -> d8756e8)

2020-02-14 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 16ee326 KAFKA-9556; Fix two issues with KIP-558 and expand testing coverage (#8085) add d8756e8 KAFKA-9274

[kafka] branch trunk updated (9da6823 -> 37d0b12)

2020-02-14 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 9da6823 HOTFIX: Fix breakage in `ConsumerPerformanceTest` (#8113) add 37d0b12 KAFKA-9512: Flaky Test

[kafka] branch 2.4 updated (161ffe1 -> e5a8961)

2020-02-13 Thread guozhang
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch 2.4 in repository https://gitbox.apache.org/repos/asf/kafka.git. from 161ffe1 MINOR: Fix poor backport that prevented compiling the MirrorMaker integration test (#8102) new a19a15f

<    1   2   3   4   5   6   7   8   9   10   >