[jira] [Created] (KAFKA-8654) Cant restart heartbeatThread if encountered unexpected exception in heartbeatloop。

nick allen created KAFKA-8654: - Summary: Cant restart heartbeatThread if encountered unexpected exception in heartbeatloop。 Key: KAFKA-8654 URL: https://issues.apache.org/jira/browse/KAFKA-8654 Project: K

[jira] [Updated] (KAFKA-8654) Cant restart heartbeatThread if encountered unexpected exception in heartbeatloop。

[ https://issues.apache.org/jira/browse/KAFKA-8654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nick allen updated KAFKA-8654: -- Description: There is a consumer in our cluster which have relatively high cpu usage for several days

[jira] [Updated] (KAFKA-8654) Cant restart heartbeatThread if encountered unexpected exception in heartbeatloop.

[ https://issues.apache.org/jira/browse/KAFKA-8654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nick allen updated KAFKA-8654: -- Summary: Cant restart heartbeatThread if encountered unexpected exception in heartbeatloop. (was: Cant

[jira] [Updated] (KAFKA-8654) Cant restart heartbeatThread if encountered unexpected exception in heartbeatloop.

[ https://issues.apache.org/jira/browse/KAFKA-8654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nick allen updated KAFKA-8654: -- Description: There is a consumer in our cluster which has relatively high cpu usage for several days c

[jira] [Updated] (KAFKA-8654) Cant restart heartbeatThread if encountered unexpected exception in heartbeatloop.

[ https://issues.apache.org/jira/browse/KAFKA-8654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nick allen updated KAFKA-8654: -- Description: There is a consumer in our cluster which has relatively high cpu usage for several days c

[jira] [Updated] (KAFKA-8654) Cant restart heartbeatThread if encountered unexpected exception in heartbeatloop.

[ https://issues.apache.org/jira/browse/KAFKA-8654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nick allen updated KAFKA-8654: -- Description: There is a consumer in our cluster which has relatively high cpu usage for several days c

[jira] [Updated] (KAFKA-8654) Cant restart heartbeatThread if encountered unexpected exception in heartbeatloop.

[ https://issues.apache.org/jira/browse/KAFKA-8654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nick allen updated KAFKA-8654: -- Description: There is a consumer in our cluster which has relatively high cpu usage for several days c

[jira] [Created] (KAFKA-8655) Failed to start systemctl kafka (code=exited, status=1/FAILURE)

Ben created KAFKA-8655: -- Summary: Failed to start systemctl kafka (code=exited, status=1/FAILURE) Key: KAFKA-8655 URL: https://issues.apache.org/jira/browse/KAFKA-8655 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-8602) StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic

[ https://issues.apache.org/jira/browse/KAFKA-8602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882837#comment-16882837 ] ASF GitHub Bot commented on KAFKA-8602: --- cadonna commented on pull request #7008: K

[jira] [Commented] (KAFKA-8602) StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic

[ https://issues.apache.org/jira/browse/KAFKA-8602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882839#comment-16882839 ] ASF GitHub Bot commented on KAFKA-8602: --- cadonna commented on pull request #7008: K

[jira] [Commented] (KAFKA-8629) Kafka Streams Apps to support small native images through GraalVM

[ https://issues.apache.org/jira/browse/KAFKA-8629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883067#comment-16883067 ] Staffan Olsson commented on KAFKA-8629: --- Quarkus has a [Streams extension|[https:/

[jira] [Comment Edited] (KAFKA-8629) Kafka Streams Apps to support small native images through GraalVM

[ https://issues.apache.org/jira/browse/KAFKA-8629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883067#comment-16883067 ] Staffan Olsson edited comment on KAFKA-8629 at 7/11/19 3:08 PM: ---

[jira] [Comment Edited] (KAFKA-8629) Kafka Streams Apps to support small native images through GraalVM

[ https://issues.apache.org/jira/browse/KAFKA-8629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883067#comment-16883067 ] Staffan Olsson edited comment on KAFKA-8629 at 7/11/19 3:08 PM: ---

[jira] [Comment Edited] (KAFKA-8629) Kafka Streams Apps to support small native images through GraalVM

[ https://issues.apache.org/jira/browse/KAFKA-8629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883067#comment-16883067 ] Staffan Olsson edited comment on KAFKA-8629 at 7/11/19 3:08 PM: ---

[jira] [Updated] (KAFKA-7440) Use leader epoch in consumer fetch requests

[ https://issues.apache.org/jira/browse/KAFKA-7440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Olson updated KAFKA-7440: Component/s: consumer > Use leader epoch in consumer fetch requests > -

[jira] [Updated] (KAFKA-8294) Batch StopReplica requests with partition deletion and add test cases

[ https://issues.apache.org/jira/browse/KAFKA-8294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Olson updated KAFKA-8294: Component/s: controller > Batch StopReplica requests with partition deletion and add test cases > -

[jira] [Updated] (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:all-tabpanel ] Andrew Olson updated KAFKA-3143: Component/s: controller > inconsistent state in ZK when all replicas are dead > ---

[jira] [Updated] (KAFKA-7831) Consumer SubscriptionState missing synchronization

[ https://issues.apache.org/jira/browse/KAFKA-7831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Olson updated KAFKA-7831: Component/s: consumer > Consumer SubscriptionState missing synchronization > --

[jira] [Updated] (KAFKA-7912) In-memory key-value store does not support concurrent access

[ https://issues.apache.org/jira/browse/KAFKA-7912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Olson updated KAFKA-7912: Component/s: streams > In-memory key-value store does not support concurrent access >

[jira] [Updated] (KAFKA-7974) KafkaAdminClient loses worker thread/enters zombie state when initial DNS lookup fails

[ https://issues.apache.org/jira/browse/KAFKA-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Olson updated KAFKA-7974: Component/s: admin > KafkaAdminClient loses worker thread/enters zombie state when initial DNS > l

[jira] [Updated] (KAFKA-8275) NetworkClient leastLoadedNode selection should consider throttled nodes

[ https://issues.apache.org/jira/browse/KAFKA-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Olson updated KAFKA-8275: Component/s: network > NetworkClient leastLoadedNode selection should consider throttled nodes > --

[jira] [Updated] (KAFKA-8275) NetworkClient leastLoadedNode selection should consider throttled nodes

[ https://issues.apache.org/jira/browse/KAFKA-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Olson updated KAFKA-8275: Component/s: clients > NetworkClient leastLoadedNode selection should consider throttled nodes > --

[jira] [Updated] (KAFKA-8324) User constructed RocksObjects leak memory

[ https://issues.apache.org/jira/browse/KAFKA-8324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Olson updated KAFKA-8324: Component/s: streams > User constructed RocksObjects leak memory >

[jira] [Updated] (KAFKA-8344) Fix vagrant-up.sh to work with AWS properly

[ https://issues.apache.org/jira/browse/KAFKA-8344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Olson updated KAFKA-8344: Component/s: system tests > Fix vagrant-up.sh to work with AWS properly > -

[jira] [Updated] (KAFKA-8483) Possible reordering of messages by producer after UNKNOWN_PRODUCER_ID error

[ https://issues.apache.org/jira/browse/KAFKA-8483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Olson updated KAFKA-8483: Component/s: producer > Possible reordering of messages by producer after UNKNOWN_PRODUCER_ID erro

[jira] [Updated] (KAFKA-8463) Fix redundant reassignment of tasks when leader worker leaves

[ https://issues.apache.org/jira/browse/KAFKA-8463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Olson updated KAFKA-8463: Component/s: KafkaConnect > Fix redundant reassignment of tasks when leader worker leaves > ---

[jira] [Updated] (KAFKA-8484) ProducerId reset can cause IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Olson updated KAFKA-8484: Component/s: producer > ProducerId reset can cause IllegalStateException > ---

[jira] [Commented] (KAFKA-8484) ProducerId reset can cause IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883132#comment-16883132 ] Andrew Olson commented on KAFKA-8484: - https://github.com/apache/kafka/pull/6883 > P

[jira] [Updated] (KAFKA-7862) Modify JoinGroup logic to incorporate group.instance.id change

[ https://issues.apache.org/jira/browse/KAFKA-7862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Olson updated KAFKA-7862: Component/s: consumer > Modify JoinGroup logic to incorporate group.instance.id change > --

[jira] [Assigned] (KAFKA-8629) Kafka Streams Apps to support small native images through GraalVM

[ https://issues.apache.org/jira/browse/KAFKA-8629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8629: -- Assignee: Andy Muir > Kafka Streams Apps to support small native images through GraalV

[jira] [Commented] (KAFKA-8629) Kafka Streams Apps to support small native images through GraalVM

[ https://issues.apache.org/jira/browse/KAFKA-8629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883135#comment-16883135 ] Matthias J. Sax commented on KAFKA-8629: [~muirandy] – I added you to the list on

[jira] [Created] (KAFKA-8656) Kafka Consumer Record Latency Metric

Sean Glover created KAFKA-8656: -- Summary: Kafka Consumer Record Latency Metric Key: KAFKA-8656 URL: https://issues.apache.org/jira/browse/KAFKA-8656 Project: Kafka Issue Type: New Feature

[jira] [Updated] (KAFKA-8656) Kafka Consumer Record Latency Metric

[ https://issues.apache.org/jira/browse/KAFKA-8656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Glover updated KAFKA-8656: --- Description: Consumer lag is a useful metric to monitor how many records are queued to be processed.

[jira] [Resolved] (KAFKA-8644) The Kafka protocol generator should allow null defaults for bytes and array fields

[ https://issues.apache.org/jira/browse/KAFKA-8644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-8644. - Resolution: Fixed Fix Version/s: 2.4.0 > The Kafka protocol generator should allow null de

[jira] [Commented] (KAFKA-8644) The Kafka protocol generator should allow null defaults for bytes and array fields

[ https://issues.apache.org/jira/browse/KAFKA-8644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883170#comment-16883170 ] ASF GitHub Bot commented on KAFKA-8644: --- gwenshap commented on pull request #7059:

[jira] [Created] (KAFKA-8657) Automatic Topic Creation on Producer

Justine Olshan created KAFKA-8657: - Summary: Automatic Topic Creation on Producer Key: KAFKA-8657 URL: https://issues.apache.org/jira/browse/KAFKA-8657 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-8657) Automatic Topic Creation on Producer

[ https://issues.apache.org/jira/browse/KAFKA-8657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Justine Olshan updated KAFKA-8657: -- Description: Kafka has a feature that allows for the auto-creation of topics. Usually this is

[jira] [Resolved] (KAFKA-8653) Regression in JoinGroup v0 rebalance timeout handling

[ https://issues.apache.org/jira/browse/KAFKA-8653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8653. Resolution: Fixed Fix Version/s: 2.3.1 > Regression in JoinGroup v0 rebalance timeou

[jira] [Updated] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Srikala updated KAFKA-7500: --- Attachment: Active-Active XDCR setup.png > MirrorMaker 2.0 (KIP-382) > - > >

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883201#comment-16883201 ] Srikala commented on KAFKA-7500: [~ryannedolan]  translateOffsets() has worked for both f

[jira] [Commented] (KAFKA-8648) Console tools should fail fast if an unrecognised --property is passed in

[ https://issues.apache.org/jira/browse/KAFKA-8648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883261#comment-16883261 ] Stanislav Kozlovski commented on KAFKA-8648: You might want to assign yoursel

[jira] [Commented] (KAFKA-8634) Update ZooKeeper to 3.5.5

[ https://issues.apache.org/jira/browse/KAFKA-8634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883294#comment-16883294 ] James Cheng commented on KAFKA-8634: [~ijuma]: Prior to this PR, can I use Kafka to t

[jira] [Commented] (KAFKA-8657) Automatic Topic Creation on Producer

[ https://issues.apache.org/jira/browse/KAFKA-8657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883348#comment-16883348 ] ASF GitHub Bot commented on KAFKA-8657: --- jolshan commented on pull request #7075: K

[jira] [Resolved] (KAFKA-7688) Allow byte array class for Decimal Logical Types to fix Debezium Issues

[ https://issues.apache.org/jira/browse/KAFKA-7688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-7688. --- Resolution: Fixed Fix Version/s: (was: 1.1.1) This issue was resol

[jira] [Updated] (KAFKA-4028) Add Connect cluster ID and expose it in REST API

[ https://issues.apache.org/jira/browse/KAFKA-4028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-4028: -- Labels: needs-kip (was: ) > Add Connect cluster ID and expose it in REST API >

[jira] [Commented] (KAFKA-4159) Allow overriding producer & consumer properties at the connector level

[ https://issues.apache.org/jira/browse/KAFKA-4159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883380#comment-16883380 ] Konstantine Karantasis commented on KAFKA-4159: --- This functionality was dis

[jira] [Comment Edited] (KAFKA-4159) Allow overriding producer & consumer properties at the connector level

[ https://issues.apache.org/jira/browse/KAFKA-4159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883380#comment-16883380 ] Konstantine Karantasis edited comment on KAFKA-4159 at 7/11/19 10:40 PM: --

[jira] [Comment Edited] (KAFKA-4159) Allow overriding producer & consumer properties at the connector level

[ https://issues.apache.org/jira/browse/KAFKA-4159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883380#comment-16883380 ] Konstantine Karantasis edited comment on KAFKA-4159 at 7/11/19 10:40 PM: --

[jira] [Commented] (KAFKA-5000) Framework should log some progress information regularly to assist in troubleshooting

[ https://issues.apache.org/jira/browse/KAFKA-5000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883385#comment-16883385 ] Konstantine Karantasis commented on KAFKA-5000: --- Now that Connect metrics h

[jira] [Updated] (KAFKA-4400) Prefix for sink task consumer groups should be configurable

[ https://issues.apache.org/jira/browse/KAFKA-4400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-4400: -- Labels: needs-kip newbie (was: newbie) > Prefix for sink task consumer groups

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

[ https://issues.apache.org/jira/browse/KAFKA-4353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-4353: -- Labels: needs-kip (was: ) > Add semantic types to Kafka Connect >

[jira] [Resolved] (KAFKA-8424) Replace ListGroups request/response with automated protocol

[ https://issues.apache.org/jira/browse/KAFKA-8424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8424. Resolution: Fixed > Replace ListGroups request/response with automated protocol > -

[jira] [Commented] (KAFKA-8502) Flakey test AdminClientIntegrationTest#testElectUncleanLeadersForAllPartitions

[ https://issues.apache.org/jira/browse/KAFKA-8502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883390#comment-16883390 ] Boyang Chen commented on KAFKA-8502: [https://builds.apache.org/job/kafka-pr-jdk11-sc

[jira] [Commented] (KAFKA-5538) User-specified Producer/Consumer config doesn't effect with KafkaBackingStore(Config/Status/Offset)

[ https://issues.apache.org/jira/browse/KAFKA-5538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883396#comment-16883396 ] Konstantine Karantasis commented on KAFKA-5538: --- It's been a while since th

[jira] [Comment Edited] (KAFKA-5538) User-specified Producer/Consumer config doesn't effect with KafkaBackingStore(Config/Status/Offset)

[ https://issues.apache.org/jira/browse/KAFKA-5538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883396#comment-16883396 ] Konstantine Karantasis edited comment on KAFKA-5538 at 7/11/19 11:17 PM: --

[jira] [Commented] (KAFKA-5635) KIP-181 Kafka-Connect integrate with kafka ReST Proxy

[ https://issues.apache.org/jira/browse/KAFKA-5635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883397#comment-16883397 ] Konstantine Karantasis commented on KAFKA-5635: --- Closing given [~ewencp] re

[jira] [Resolved] (KAFKA-5635) KIP-181 Kafka-Connect integrate with kafka ReST Proxy

[ https://issues.apache.org/jira/browse/KAFKA-5635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-5635. --- Resolution: Won't Fix > KIP-181 Kafka-Connect integrate with kafka ReST Proxy

[jira] [Updated] (KAFKA-5699) Validate and Create connector endpoint should take the same format message body

[ https://issues.apache.org/jira/browse/KAFKA-5699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-5699: -- Labels: needs-kip (was: ) > Validate and Create connector endpoint should take

[jira] [Updated] (KAFKA-5688) Add a modifier to the REST endpoint to only show errors

[ https://issues.apache.org/jira/browse/KAFKA-5688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-5688: -- Labels: needs-kip (was: ) > Add a modifier to the REST endpoint to only show e

[jira] [Commented] (KAFKA-5696) SourceConnector does not commit offset on rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883401#comment-16883401 ] Konstantine Karantasis commented on KAFKA-5696: --- Now that https://issues.ap

[jira] [Commented] (KAFKA-5741) Prioritize threads in Connect distributed worker process

[ https://issues.apache.org/jira/browse/KAFKA-5741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883402#comment-16883402 ] Konstantine Karantasis commented on KAFKA-5741: --- [~rhauch] [~ewencp] do we

[jira] [Commented] (KAFKA-5740) Use separate file for HTTP logs

[ https://issues.apache.org/jira/browse/KAFKA-5740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883403#comment-16883403 ] Konstantine Karantasis commented on KAFKA-5740: --- Now that https://cwiki.ap

[jira] [Updated] (KAFKA-4793) Kafka Connect: POST /connectors/(string: name)/restart doesn't start failed tasks

[ https://issues.apache.org/jira/browse/KAFKA-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-4793: -- Labels: needs-kip (was: ) > Kafka Connect: POST /connectors/(string: name)/res

[jira] [Updated] (KAFKA-5716) Connect: When SourceTask.commit it is possible not everthing from SourceTask.poll has been sent

[ https://issues.apache.org/jira/browse/KAFKA-5716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-5716: -- Labels: needs-kip (was: ) > Connect: When SourceTask.commit it is possible not

[jira] [Commented] (KAFKA-5827) Allow configuring Kafka sink connectors to start processing records from the end of topics

[ https://issues.apache.org/jira/browse/KAFKA-5827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883409#comment-16883409 ] Konstantine Karantasis commented on KAFKA-5827: --- Now that https://issues.ap

[jira] [Issue Comment Deleted] (KAFKA-5827) Allow configuring Kafka sink connectors to start processing records from the end of topics

[ https://issues.apache.org/jira/browse/KAFKA-5827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-5827: -- Comment: was deleted (was: Now that https://issues.apache.org/jira/browse/KAFKA

[jira] [Commented] (KAFKA-5827) Allow configuring Kafka sink connectors to start processing records from the end of topics

[ https://issues.apache.org/jira/browse/KAFKA-5827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883410#comment-16883410 ] Konstantine Karantasis commented on KAFKA-5827: --- cc [~rhauch] [~ewencp] >

[jira] [Commented] (KAFKA-5866) Let source/sink task to finish their job before exit

[ https://issues.apache.org/jira/browse/KAFKA-5866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883413#comment-16883413 ] Konstantine Karantasis commented on KAFKA-5866: --- Now that https://issues.ap

[jira] [Issue Comment Deleted] (KAFKA-5827) Allow configuring Kafka sink connectors to start processing records from the end of topics

[ https://issues.apache.org/jira/browse/KAFKA-5827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-5827: -- Comment: was deleted (was: cc [~rhauch] [~ewencp]) > Allow configuring Kafka s

[jira] [Commented] (KAFKA-8637) WriteBatch objects leak off-heap memory

[ https://issues.apache.org/jira/browse/KAFKA-8637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883417#comment-16883417 ] ASF GitHub Bot commented on KAFKA-8637: --- ableegoldman commented on pull request #70

[jira] [Commented] (KAFKA-8643) Incompatible MemberDescription constructor change

[ https://issues.apache.org/jira/browse/KAFKA-8643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883526#comment-16883526 ] ASF GitHub Bot commented on KAFKA-8643: --- hachikuji commented on pull request #7060: