[jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16468686#comment-16468686 ] ASF GitHub Bot commented on KAFKA-6474: --- h314to opened a new pull request #4986: KAFKA-6474: Rewrite

[jira] [Commented] (KAFKA-6834) log cleaner should handle the case when the size of a message set is larger than the max message size

[ https://issues.apache.org/jira/browse/KAFKA-6834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16468693#comment-16468693 ] ASF GitHub Bot commented on KAFKA-6834: --- rajinisivaram closed pull request #4953: KAFKA-6834: Handle

[jira] [Commented] (KAFKA-6264) Log cleaner thread may die on legacy segment containing messages whose offsets are too large

[ https://issues.apache.org/jira/browse/KAFKA-6264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466651#comment-16466651 ] ASF GitHub Bot commented on KAFKA-6264: --- dhruvilshah3 opened a new pull request #4975: KAFKA-6264:

[jira] [Commented] (KAFKA-6879) Controller deadlock following session expiration

[ https://issues.apache.org/jira/browse/KAFKA-6879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466901#comment-16466901 ] ASF GitHub Bot commented on KAFKA-6879: --- hachikuji opened a new pull request #4977: KAFKA-6879;

[jira] [Commented] (KAFKA-6813) Remove deprecated APIs from KIP-120 and KIP-182 in Streams

[ https://issues.apache.org/jira/browse/KAFKA-6813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466684#comment-16466684 ] ASF GitHub Bot commented on KAFKA-6813: --- guozhangwang opened a new pull request #4976: KAFKA-6813:

[jira] [Commented] (KAFKA-6877) Remove completedFetch upon a failed parse if it contains no records.

[ https://issues.apache.org/jira/browse/KAFKA-6877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16468221#comment-16468221 ] ASF GitHub Bot commented on KAFKA-6877: --- becketqin closed pull request #4974: KAFKA-6877; Remove

[jira] [Commented] (KAFKA-6761) Reduce Kafka Streams Footprint

[ https://issues.apache.org/jira/browse/KAFKA-6761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16468244#comment-16468244 ] ASF GitHub Bot commented on KAFKA-6761: --- bbejeck opened a new pull request #4983: KAFKA-6761 [WIP]-

[jira] [Commented] (KAFKA-6786) Remove additional configs in StreamsBrokerDownResilienceTest

[ https://issues.apache.org/jira/browse/KAFKA-6786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16468243#comment-16468243 ] ASF GitHub Bot commented on KAFKA-6786: --- abhishek7 opened a new pull request #4982: KAFKA-6786 URL:

[jira] [Commented] (KAFKA-6292) KafkaConsumer ran into Unknown error fetching data for topic-partition caused by integer overflow in FileLogInputStream

[ https://issues.apache.org/jira/browse/KAFKA-6292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16468133#comment-16468133 ] ASF GitHub Bot commented on KAFKA-6292: --- hachikuji closed pull request #4928: KAFKA-6292: Improved

[jira] [Commented] (KAFKA-6863) Kafka clients should try to use multiple DNS resolved IP addresses if the first one fails

[ https://issues.apache.org/jira/browse/KAFKA-6863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16468929#comment-16468929 ] ASF GitHub Bot commented on KAFKA-6863: --- edoardocomar opened a new pull request #4987: KAFKA-6863

[jira] [Commented] (KAFKA-3689) Exception when attempting to decrease connection count for address with no connections

[ https://issues.apache.org/jira/browse/KAFKA-3689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16468902#comment-16468902 ] ASF GitHub Bot commented on KAFKA-3689: --- rnpridgeon closed pull request #1658: KAFKA-3689 - process

[jira] [Commented] (KAFKA-5691) ZKUtils.CreateRecursive should handle NOAUTH

[ https://issues.apache.org/jira/browse/KAFKA-5691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16468885#comment-16468885 ] ASF GitHub Bot commented on KAFKA-5691: --- rnpridgeon closed pull request #3608: KAFKA-5691- handle

[jira] [Commented] (KAFKA-4353) Add semantic types to Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-4353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16468869#comment-16468869 ] ASF GitHub Bot commented on KAFKA-4353: --- rnpridgeon closed pull request #2334: subset of KAFKA-4353:

[jira] [Commented] (KAFKA-6878) NPE when querying global state store not in READY state

[ https://issues.apache.org/jira/browse/KAFKA-6878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16469182#comment-16469182 ] ASF GitHub Bot commented on KAFKA-6878: --- guozhangwang closed pull request #4978: KAFKA-6878 NPE when

[jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16456764#comment-16456764 ] ASF GitHub Bot commented on KAFKA-6474: --- h314to opened a new pull request #4939: KAFKA-6474: Rewrite

[jira] [Commented] (KAFKA-6813) Remove deprecated APIs from KIP-120 and KIP-182 in Streams

[ https://issues.apache.org/jira/browse/KAFKA-6813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16469687#comment-16469687 ] ASF GitHub Bot commented on KAFKA-6813: --- guozhangwang opened a new pull request #4991: KAFKA-6813:

[jira] [Commented] (KAFKA-6299) Fix AdminClient error handling when metadata changes

[ https://issues.apache.org/jira/browse/KAFKA-6299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16469557#comment-16469557 ] ASF GitHub Bot commented on KAFKA-6299: --- hachikuji opened a new pull request #4989: MINOR: A few

[jira] [Commented] (KAFKA-6361) Fast leader fail over can lead to log divergence between leader and follower

[ https://issues.apache.org/jira/browse/KAFKA-6361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16469805#comment-16469805 ] ASF GitHub Bot commented on KAFKA-6361: --- junrao closed pull request #4882: KAFKA-6361: Fix log

[jira] [Commented] (KAFKA-6299) Fix AdminClient error handling when metadata changes

[ https://issues.apache.org/jira/browse/KAFKA-6299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16469537#comment-16469537 ] ASF GitHub Bot commented on KAFKA-6299: --- hachikuji closed pull request #4295: KAFKA-6299. Fix

[jira] [Commented] (KAFKA-6813) Remove deprecated APIs from KIP-120 and KIP-182 in Streams

[ https://issues.apache.org/jira/browse/KAFKA-6813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16469741#comment-16469741 ] ASF GitHub Bot commented on KAFKA-6813: --- guozhangwang closed pull request #4976: KAFKA-6813: Remove

[jira] [Commented] (KAFKA-6891) send.buffer.bytes should be allowed to set -1 in KafkaConnect

[ https://issues.apache.org/jira/browse/KAFKA-6891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470065#comment-16470065 ] ASF GitHub Bot commented on KAFKA-6891: --- oleg-smith opened a new pull request #4995: KAFKA-6891

[jira] [Commented] (KAFKA-6890) Add connector level configurability for producer/consumer client configs

[ https://issues.apache.org/jira/browse/KAFKA-6890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470566#comment-16470566 ] ASF GitHub Bot commented on KAFKA-6890: --- natengall opened a new pull request #4997: KAFKA-6890: Add

[jira] [Commented] (KAFKA-6894) Cannot access GlobalKTable store from KStream.transform()

[ https://issues.apache.org/jira/browse/KAFKA-6894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470980#comment-16470980 ] ASF GitHub Bot commented on KAFKA-6894: --- rayokota opened a new pull request #5000: KAFKA-6894: Fix

[jira] [Commented] (KAFKA-6893) Processors created after acceptor started which can cause in a brief refusal to accept connections

[ https://issues.apache.org/jira/browse/KAFKA-6893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471130#comment-16471130 ] ASF GitHub Bot commented on KAFKA-6893: --- hachikuji closed pull request #4999: KAFKA-6893: Create

[jira] [Commented] (KAFKA-6894) Improve error message when connecting processor with a global store

[ https://issues.apache.org/jira/browse/KAFKA-6894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471254#comment-16471254 ] ASF GitHub Bot commented on KAFKA-6894: --- guozhangwang closed pull request #5000: KAFKA-6894: Improve

[jira] [Commented] (KAFKA-6049) Kafka Streams: Add Cogroup in the DSL

[ https://issues.apache.org/jira/browse/KAFKA-6049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473237#comment-16473237 ] ASF GitHub Bot commented on KAFKA-6049: --- ConcurrencyPractitioner closed pull request #4646:

[jira] [Commented] (KAFKA-4696) Streams standby task assignment should be state-store aware

[ https://issues.apache.org/jira/browse/KAFKA-4696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473240#comment-16473240 ] ASF GitHub Bot commented on KAFKA-4696: --- ConcurrencyPractitioner closed pull request #4615:

[jira] [Commented] (KAFKA-6608) Add TimeoutException to KafkaConsumer#position()

[ https://issues.apache.org/jira/browse/KAFKA-6608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473239#comment-16473239 ] ASF GitHub Bot commented on KAFKA-6608: --- ConcurrencyPractitioner closed pull request #4643:

[jira] [Commented] (KAFKA-6730) Simplify state store recovery

[ https://issues.apache.org/jira/browse/KAFKA-6730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473238#comment-16473238 ] ASF GitHub Bot commented on KAFKA-6730: --- ConcurrencyPractitioner closed pull request #4901:

[jira] [Commented] (KAFKA-6608) Add TimeoutException to KafkaConsumer#position()

[ https://issues.apache.org/jira/browse/KAFKA-6608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473251#comment-16473251 ] ASF GitHub Bot commented on KAFKA-6608: --- ConcurrencyPractitioner opened a new pull request #5014:

[jira] [Commented] (KAFKA-6730) Simplify state store recovery

[ https://issues.apache.org/jira/browse/KAFKA-6730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473248#comment-16473248 ] ASF GitHub Bot commented on KAFKA-6730: --- ConcurrencyPractitioner opened a new pull request #5013:

[jira] [Commented] (KAFKA-4696) Streams standby task assignment should be state-store aware

[ https://issues.apache.org/jira/browse/KAFKA-4696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473245#comment-16473245 ] ASF GitHub Bot commented on KAFKA-4696: --- ConcurrencyPractitioner opened a new pull request #5012:

[jira] [Commented] (KAFKA-6749) TopologyTestDriver fails when topoloy under test uses EXACTLY_ONCE

[ https://issues.apache.org/jira/browse/KAFKA-6749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472905#comment-16472905 ] ASF GitHub Bot commented on KAFKA-6749: --- jadireddi closed pull request #4912: KAFKA-6749: Fixed

[jira] [Commented] (KAFKA-6749) TopologyTestDriver fails when topoloy under test uses EXACTLY_ONCE

[ https://issues.apache.org/jira/browse/KAFKA-6749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472915#comment-16472915 ] ASF GitHub Bot commented on KAFKA-6749: --- jadireddi opened a new pull request #4912: KAFKA-6749:

[jira] [Commented] (KAFKA-6899) One Potential NPE

[ https://issues.apache.org/jira/browse/KAFKA-6899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473436#comment-16473436 ] ASF GitHub Bot commented on KAFKA-6899: --- lujiefsi opened a new pull request #5015: [KAFKA-6899] One

[jira] [Commented] (KAFKA-6725) Indicate "isClosing" in the SinkTaskContext

[ https://issues.apache.org/jira/browse/KAFKA-6725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471452#comment-16471452 ] ASF GitHub Bot commented on KAFKA-6725: --- farmdawgnation opened a new pull request #5002: KAFKA-6725:

[jira] [Commented] (KAFKA-5965) Remove Deprecated AdminClient from Streams Resetter Tool

[ https://issues.apache.org/jira/browse/KAFKA-5965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472135#comment-16472135 ] ASF GitHub Bot commented on KAFKA-5965: --- guozhangwang closed pull request #4968: KAFKA-5965: Remove

[jira] [Commented] (KAFKA-6394) Prevent misconfiguration of advertised listeners

[ https://issues.apache.org/jira/browse/KAFKA-6394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472150#comment-16472150 ] ASF GitHub Bot commented on KAFKA-6394: --- hachikuji closed pull request #4897: KAFKA-6394: Add a

[jira] [Commented] (KAFKA-4849) Bug in KafkaStreams documentation

[ https://issues.apache.org/jira/browse/KAFKA-4849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472322#comment-16472322 ] ASF GitHub Bot commented on KAFKA-4849: --- mjsax closed pull request #2648: KAFKA-4849: Bug in

[jira] [Commented] (KAFKA-6299) Fix AdminClient error handling when metadata changes

[ https://issues.apache.org/jira/browse/KAFKA-6299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471322#comment-16471322 ] ASF GitHub Bot commented on KAFKA-6299: --- hachikuji closed pull request #4989: MINOR: A few small

[jira] [Commented] (KAFKA-6738) Kafka Connect handling of bad data

[ https://issues.apache.org/jira/browse/KAFKA-6738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472754#comment-16472754 ] ASF GitHub Bot commented on KAFKA-6738: --- wicknicks opened a new pull request #5010: KAFKA-6738:

[jira] [Commented] (KAFKA-6878) NPE when querying global state store not in READY state

[ https://issues.apache.org/jira/browse/KAFKA-6878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16467708#comment-16467708 ] ASF GitHub Bot commented on KAFKA-6878: --- tedyu opened a new pull request #4978: KAFKA-6878 NPE when

[jira] [Commented] (KAFKA-6264) Log cleaner thread may die on legacy segment containing messages whose offsets are too large

[ https://issues.apache.org/jira/browse/KAFKA-6264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16467795#comment-16467795 ] ASF GitHub Bot commented on KAFKA-6264: --- dhruvilshah3 closed pull request #4692: KAFKA-6264: Log

[jira] [Commented] (KAFKA-6628) RocksDBSegmentedBytesStoreTest does not cover time window serdes

[ https://issues.apache.org/jira/browse/KAFKA-6628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466252#comment-16466252 ] ASF GitHub Bot commented on KAFKA-6628: --- guozhangwang closed pull request #4836: KAFKA-6628:

[jira] [Commented] (KAFKA-6864) null is not passed to keyDeserialzer and valueDeserializer in Fetcher

[ https://issues.apache.org/jira/browse/KAFKA-6864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16463952#comment-16463952 ] ASF GitHub Bot commented on KAFKA-6864: --- makubi opened a new pull request #4969: KAFKA-6864: Pass

[jira] [Commented] (KAFKA-6911) Incorrect check for keystore/truststore dynamic update

[ https://issues.apache.org/jira/browse/KAFKA-6911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16478831#comment-16478831 ] ASF GitHub Bot commented on KAFKA-6911: --- rajinisivaram opened a new pull request #5029: KAFKA-6911:

[jira] [Commented] (KAFKA-6905) Document that Processor objects can be reused

[ https://issues.apache.org/jira/browse/KAFKA-6905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16476968#comment-16476968 ] ASF GitHub Bot commented on KAFKA-6905: --- glasser opened a new pull request #5022: KAFKA-6905:

[jira] [Commented] (KAFKA-6919) Trogdor documentation points to wrong location for trogdor.sh

[ https://issues.apache.org/jira/browse/KAFKA-6919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16481750#comment-16481750 ] ASF GitHub Bot commented on KAFKA-6919: --- KoenDG opened a new pull request #5040: KAFKA-6919: Fix for

[jira] [Commented] (KAFKA-3143) inconsistent state in ZK when all replicas are dead

[ https://issues.apache.org/jira/browse/KAFKA-3143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16481752#comment-16481752 ] ASF GitHub Bot commented on KAFKA-3143: --- omkreddy opened a new pull request #5041: KAFKA-3143:

[jira] [Commented] (KAFKA-6840) support windowing in ktable API

[ https://issues.apache.org/jira/browse/KAFKA-6840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16481825#comment-16481825 ] ASF GitHub Bot commented on KAFKA-6840: --- abbccdda opened a new pull request #5044: KAFKA-6840:

[jira] [Commented] (KAFKA-6905) Document that Processor objects can be reused

[ https://issues.apache.org/jira/browse/KAFKA-6905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16481823#comment-16481823 ] ASF GitHub Bot commented on KAFKA-6905: --- guozhangwang closed pull request #5026: KAFKA-6905:

[jira] [Commented] (KAFKA-4423) Drop support for Java 7

[ https://issues.apache.org/jira/browse/KAFKA-4423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16481834#comment-16481834 ] ASF GitHub Bot commented on KAFKA-4423: --- ijuma opened a new pull request #5046: KAFKA-4423: Drop

[jira] [Commented] (KAFKA-6912) Add authorization tests for custom principal types

[ https://issues.apache.org/jira/browse/KAFKA-6912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16479087#comment-16479087 ] ASF GitHub Bot commented on KAFKA-6912: --- rajinisivaram opened a new pull request #5030: KAFKA-6912:

[jira] [Commented] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16476251#comment-16476251 ] ASF GitHub Bot commented on KAFKA-6566: --- rayokota opened a new pull request #5020: KAFKA-6566:

[jira] [Commented] (KAFKA-6729) KTable should use user source topics if possible and not create changelog topic

[ https://issues.apache.org/jira/browse/KAFKA-6729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16479521#comment-16479521 ] ASF GitHub Bot commented on KAFKA-6729: --- guozhangwang closed pull request #5017: KAFKA-6729: Reuse

[jira] [Commented] (KAFKA-5572) ConfigDef.Type.List should support escaping comma character

[ https://issues.apache.org/jira/browse/KAFKA-5572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477704#comment-16477704 ] ASF GitHub Bot commented on KAFKA-5572: --- jcustenborder closed pull request #3508: KAFKA-5572 -

[jira] [Commented] (KAFKA-3347) Configure java to prefer ipv4

[ https://issues.apache.org/jira/browse/KAFKA-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477707#comment-16477707 ] ASF GitHub Bot commented on KAFKA-3347: --- jcustenborder closed pull request #1026: KAFKA-3347 -

[jira] [Commented] (KAFKA-6123) Give client MetricsReporter auto-generated client.id

[ https://issues.apache.org/jira/browse/KAFKA-6123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16476361#comment-16476361 ] ASF GitHub Bot commented on KAFKA-6123: --- KevinLiLu closed pull request #4637: KAFKA-6123: Give

[jira] [Commented] (KAFKA-3943) ConfigDef should support a builder pattern.

[ https://issues.apache.org/jira/browse/KAFKA-3943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477753#comment-16477753 ] ASF GitHub Bot commented on KAFKA-3943: --- jcustenborder closed pull request #1602: KAFKA-3943 -

[jira] [Commented] (KAFKA-6926) Reduce NPath exceptions in Connect

[ https://issues.apache.org/jira/browse/KAFKA-6926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16482703#comment-16482703 ] ASF GitHub Bot commented on KAFKA-6926: --- rhauch opened a new pull request #5051: KAFKA-6926:

[jira] [Commented] (KAFKA-6868) BufferUnderflowException in client when querying consumer group information

[ https://issues.apache.org/jira/browse/KAFKA-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16482631#comment-16482631 ] ASF GitHub Bot commented on KAFKA-6868: --- hachikuji closed pull request #4980: KAFKA-6868: Fix buffer

[jira] [Commented] (KAFKA-2951) Additional authorization test cases

[ https://issues.apache.org/jira/browse/KAFKA-2951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16482830#comment-16482830 ] ASF GitHub Bot commented on KAFKA-2951: --- omkreddy opened a new pull request #5054: KAFKA-2951: Add a

[jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16482758#comment-16482758 ] ASF GitHub Bot commented on KAFKA-6474: --- h314to opened a new pull request #5052: KAFKA-6474: Rewrite

[jira] [Commented] (KAFKA-1400) transient unit test failure in SocketServerTest

[ https://issues.apache.org/jira/browse/KAFKA-1400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16483195#comment-16483195 ] ASF GitHub Bot commented on KAFKA-1400: --- JimGalasyn opened a new pull request #142: KAFKA-1400: Fix

[jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484168#comment-16484168 ] ASF GitHub Bot commented on KAFKA-6474: --- guozhangwang closed pull request #5052: KAFKA-6474: Rewrite

[jira] [Commented] (KAFKA-6930) Update KafkaZkClient debug log

[ https://issues.apache.org/jira/browse/KAFKA-6930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16483999#comment-16483999 ] ASF GitHub Bot commented on KAFKA-6930: --- darionyaphet opened a new pull request #5061: [KAFKA-6930]

[jira] [Commented] (KAFKA-6937) In-sync replica delayed during fetch if replica throttle is exceeded

[ https://issues.apache.org/jira/browse/KAFKA-6937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488077#comment-16488077 ] ASF GitHub Bot commented on KAFKA-6937: --- junrao opened a new pull request #5074: KAFKA-6937: In-sync

[jira] [Commented] (KAFKA-4559) Add a site search bar on the Web site

[ https://issues.apache.org/jira/browse/KAFKA-4559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486582#comment-16486582 ] ASF GitHub Bot commented on KAFKA-4559: --- zer0Id0l opened a new pull request #143: [KAFKA-4559] Add a

[jira] [Commented] (KAFKA-6931) Make worker id configurable

[ https://issues.apache.org/jira/browse/KAFKA-6931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486772#comment-16486772 ] ASF GitHub Bot commented on KAFKA-6931: --- chia7712 opened a new pull request #5069: KAFKA-6931 Make

[jira] [Commented] (KAFKA-6886) Externalize Secrets for Kafka Connect Configurations

[ https://issues.apache.org/jira/browse/KAFKA-6886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486495#comment-16486495 ] ASF GitHub Bot commented on KAFKA-6886: --- rayokota opened a new pull request #5068: KAFKA-6886

[jira] [Commented] (KAFKA-6738) Kafka Connect handling of bad data

[ https://issues.apache.org/jira/browse/KAFKA-6738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488234#comment-16488234 ] ASF GitHub Bot commented on KAFKA-6738: --- wicknicks closed pull request #5010: KAFKA-6738: (WIP)

[jira] [Commented] (KAFKA-4290) High CPU caused by timeout overflow in WorkerCoordinator

[ https://issues.apache.org/jira/browse/KAFKA-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487117#comment-16487117 ] ASF GitHub Bot commented on KAFKA-4290: --- GitHub user thisthat opened a pull request:

[jira] [Commented] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null

[ https://issues.apache.org/jira/browse/KAFKA-6378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484502#comment-16484502 ] ASF GitHub Bot commented on KAFKA-6378: --- wicknicks opened a new pull request #5065: KAFKA-6378:

[jira] [Commented] (KAFKA-5807) Check Connector.config() and Transformation.config() returns a valid ConfigDef

[ https://issues.apache.org/jira/browse/KAFKA-5807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484561#comment-16484561 ] ASF GitHub Bot commented on KAFKA-5807: --- ewencp closed pull request #3762: KAFKA-5807 - Check

[jira] [Commented] (KAFKA-6850) KIP-244: Add Record Header support to Kafka Streams Processor API

[ https://issues.apache.org/jira/browse/KAFKA-6850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484711#comment-16484711 ] ASF GitHub Bot commented on KAFKA-6850: --- mjsax closed pull request #4955: KAFKA-6850: Add Record

[jira] [Commented] (KAFKA-6948) Avoid overflow in timestamp comparison

[ https://issues.apache.org/jira/browse/KAFKA-6948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16490417#comment-16490417 ] ASF GitHub Bot commented on KAFKA-6948: --- thisthat opened a new pull request #5078: KAFKA-6948 Change

[jira] [Commented] (KAFKA-6841) Add support for wildcard suffixed ACLs

[ https://issues.apache.org/jira/browse/KAFKA-6841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16490480#comment-16490480 ] ASF GitHub Bot commented on KAFKA-6841: --- piyushvijay opened a new pull request #5079: [WIP]

[jira] [Commented] (KAFKA-6900) Add thenCompose to KafkaFuture

[ https://issues.apache.org/jira/browse/KAFKA-6900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16490546#comment-16490546 ] ASF GitHub Bot commented on KAFKA-6900: --- RichoDemus opened a new pull request #5080: KAFKA-6900: Add

[jira] [Commented] (KAFKA-6937) In-sync replica delayed during fetch if replica throttle is exceeded

[ https://issues.apache.org/jira/browse/KAFKA-6937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16491384#comment-16491384 ] ASF GitHub Bot commented on KAFKA-6937: --- junrao closed pull request #5074: KAFKA-6937: In-sync

[jira] [Commented] (KAFKA-6930) Update KafkaZkClient debug log

[ https://issues.apache.org/jira/browse/KAFKA-6930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16491394#comment-16491394 ] ASF GitHub Bot commented on KAFKA-6930: --- ijuma closed pull request #5061: [KAFKA-6930] Update

[jira] [Commented] (KAFKA-6950) Add mechanism to delay response to failed client authentication

[ https://issues.apache.org/jira/browse/KAFKA-6950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16491439#comment-16491439 ] ASF GitHub Bot commented on KAFKA-6950: --- dhruvilshah3 opened a new pull request #5082: KAFKA-6950:

[jira] [Commented] (KAFKA-6949) alterReplicaLogDirs() should grab partition lock when accessing log of the future replica

[ https://issues.apache.org/jira/browse/KAFKA-6949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16491438#comment-16491438 ] ASF GitHub Bot commented on KAFKA-6949: --- lindong28 opened a new pull request #5081: KAFKA-6949;

[jira] [Commented] (KAFKA-2951) Additional authorization test cases

[ https://issues.apache.org/jira/browse/KAFKA-2951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16491544#comment-16491544 ] ASF GitHub Bot commented on KAFKA-2951: --- hachikuji closed pull request #5054: KAFKA-2951: Add a

[jira] [Commented] (KAFKA-6813) Remove deprecated APIs from KIP-120 and KIP-182 in Streams

[ https://issues.apache.org/jira/browse/KAFKA-6813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489641#comment-16489641 ] ASF GitHub Bot commented on KAFKA-6813: --- vvcephei opened a new pull request #5075: KAFKA-6813:

[jira] [Commented] (KAFKA-6941) when passing port = 0 to worker, the advertisedPort still is 0 rather than a random port

[ https://issues.apache.org/jira/browse/KAFKA-6941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16490114#comment-16490114 ] ASF GitHub Bot commented on KAFKA-6941: --- chia7712 opened a new pull request #5076: KAFKA-6941 when

[jira] [Commented] (KAFKA-6911) Incorrect check for keystore/truststore dynamic update

[ https://issues.apache.org/jira/browse/KAFKA-6911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489975#comment-16489975 ] ASF GitHub Bot commented on KAFKA-6911: --- hachikuji closed pull request #5029: KAFKA-6911: Fix

[jira] [Commented] (KAFKA-5697) StreamThread.shutdown() need to interrupt the stream threads to break the loop

[ https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16480778#comment-16480778 ] ASF GitHub Bot commented on KAFKA-5697: --- guozhangwang closed pull request #5035: KAFKA-5697: Revert

[jira] [Commented] (KAFKA-6917) Request handler deadlocks attempting to acquire group metadata lock

[ https://issues.apache.org/jira/browse/KAFKA-6917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16480706#comment-16480706 ] ASF GitHub Bot commented on KAFKA-6917: --- rajinisivaram opened a new pull request #5036: KAFKA-6917:

[jira] [Commented] (KAFKA-6917) Request handler deadlocks attempting to acquire group metadata lock

[ https://issues.apache.org/jira/browse/KAFKA-6917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16481159#comment-16481159 ] ASF GitHub Bot commented on KAFKA-6917: --- hachikuji closed pull request #5036: KAFKA-6917: Process

[jira] [Commented] (KAFKA-6913) Add primitive numeric converters to Connect

[ https://issues.apache.org/jira/browse/KAFKA-6913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16479859#comment-16479859 ] ASF GitHub Bot commented on KAFKA-6913: --- rhauch opened a new pull request #5034: KAFKA-6913: Add

[jira] [Commented] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16480970#comment-16480970 ] ASF GitHub Bot commented on KAFKA-6566: --- ewencp closed pull request #5020: KAFKA-6566: Improve

[jira] [Commented] (KAFKA-6729) KTable should use user source topics if possible and not create changelog topic

[ https://issues.apache.org/jira/browse/KAFKA-6729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16481305#comment-16481305 ] ASF GitHub Bot commented on KAFKA-6729: --- guozhangwang opened a new pull request #5038: KAFKA-6729:

[jira] [Commented] (KAFKA-3355) GetOffsetShell command doesn't work with SASL enabled Kafka

[ https://issues.apache.org/jira/browse/KAFKA-3355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16478431#comment-16478431 ] ASF GitHub Bot commented on KAFKA-3355: --- murong00 opened a new pull request #5028: KAFKA-3355: Fix

[jira] [Commented] (KAFKA-5994) Improve transparency of broker user ACL misconfigurations

[ https://issues.apache.org/jira/browse/KAFKA-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16476754#comment-16476754 ] ASF GitHub Bot commented on KAFKA-5994: --- omkreddy opened a new pull request #5021: KAFKA-5994: Log

[jira] [Commented] (KAFKA-6905) Document that Processor objects can be reused

[ https://issues.apache.org/jira/browse/KAFKA-6905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16478128#comment-16478128 ] ASF GitHub Bot commented on KAFKA-6905: --- glasser opened a new pull request #5026: KAFKA-6905:

[jira] [Commented] (KAFKA-6905) Document that Processor objects can be reused

[ https://issues.apache.org/jira/browse/KAFKA-6905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16478005#comment-16478005 ] ASF GitHub Bot commented on KAFKA-6905: --- guozhangwang closed pull request #5022: KAFKA-6905:

[jira] [Commented] (KAFKA-6896) add producer metrics exporting in KafkaStreams.java

[ https://issues.apache.org/jira/browse/KAFKA-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16476497#comment-16476497 ] ASF GitHub Bot commented on KAFKA-6896: --- guozhangwang closed pull request #4998: KAFKA-6896: Add

[jira] [Commented] (KAFKA-6935) KIP-295 Add Streams Config for Optional Optimization

[ https://issues.apache.org/jira/browse/KAFKA-6935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487414#comment-16487414 ] ASF GitHub Bot commented on KAFKA-6935: --- bbejeck opened a new pull request #5071: KAFKA-6935: Add

[jira] [Commented] (KAFKA-6028) Improve the quota throttle communication.

[ https://issues.apache.org/jira/browse/KAFKA-6028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484394#comment-16484394 ] ASF GitHub Bot commented on KAFKA-6028: --- jonlee2 opened a new pull request #5064: KAFKA-6028:

[jira] [Commented] (KAFKA-6916) AdminClient does not refresh metadata on broker failure

[ https://issues.apache.org/jira/browse/KAFKA-6916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16482281#comment-16482281 ] ASF GitHub Bot commented on KAFKA-6916: --- rajinisivaram opened a new pull request #5050: KAFKA-6916:

<    5   6   7   8   9   10   11   12   13   14   >