[jira] [Resolved] (KAFKA-10301) Partition#remoteReplicasMap can be empty in certain race conditions

2020-07-27 Thread Stanislav Kozlovski (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski resolved KAFKA-10301. - Resolution: Fixed > Partition#remoteReplicasMap can be empty in certain race con

[jira] [Commented] (KAFKA-10301) Partition#remoteReplicasMap can be empty in certain race conditions

2020-07-27 Thread Stanislav Kozlovski (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165484#comment-17165484 ] Stanislav Kozlovski commented on KAFKA-10301: - Merged in master ([fa6e5b892

[jira] [Commented] (KAFKA-10302) Ensure thread-safe access to Partition#remoteReplicasMap

2020-07-27 Thread Stanislav Kozlovski (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165489#comment-17165489 ] Stanislav Kozlovski commented on KAFKA-10302: - [~johnthotekat] I have not, n

[GitHub] [kafka] viktorsomogyi commented on pull request #4090: [KAFKA-6084] Propagate JSON parsing errors in ReassignPartitionsCommand

2020-07-27 Thread GitBox
viktorsomogyi commented on pull request #4090: URL: https://github.com/apache/kafka/pull/4090#issuecomment-664175913 retest this please This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [kafka] viktorsomogyi commented on pull request #8730: KAFKA-10048: Possible data gap for a consumer after a failover when u…

2020-07-27 Thread GitBox
viktorsomogyi commented on pull request #8730: URL: https://github.com/apache/kafka/pull/8730#issuecomment-664176258 @ijuma would you please review this or suggest who is the right committer to help with this? This is an aut

[GitHub] [kafka] ijuma commented on pull request #8730: KAFKA-10048: Possible data gap for a consumer after a failover when u…

2020-07-27 Thread GitBox
ijuma commented on pull request #8730: URL: https://github.com/apache/kafka/pull/8730#issuecomment-664180174 @mimaison, would you be able to review this? This is an automated message from the Apache Git Service. To respond to

[GitHub] [kafka] ijuma commented on a change in pull request #4090: [KAFKA-6084] Propagate JSON parsing errors in ReassignPartitionsCommand

2020-07-27 Thread GitBox
ijuma commented on a change in pull request #4090: URL: https://github.com/apache/kafka/pull/4090#discussion_r460711206 ## File path: core/src/test/scala/unit/kafka/utils/JsonTest.scala ## @@ -41,14 +42,23 @@ class JsonTest { val jnf = JsonNodeFactory.instance asser

[GitHub] [kafka] ijuma commented on a change in pull request #9067: MINOR: Streams integration tests should not call exit

2020-07-27 Thread GitBox
ijuma commented on a change in pull request #9067: URL: https://github.com/apache/kafka/pull/9067#discussion_r460714125 ## File path: checkstyle/suppressions.xml ## @@ -17,8 +17,14 @@ files="(ApiMessageType).java|MessageDataGenerator.java"/> + +

[GitHub] [kafka] ijuma commented on a change in pull request #9067: MINOR: Streams integration tests should not call exit

2020-07-27 Thread GitBox
ijuma commented on a change in pull request #9067: URL: https://github.com/apache/kafka/pull/9067#discussion_r460714547 ## File path: streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerDemo.java ## @@ -153,8 +154,8 @@ public void run

[GitHub] [kafka] ijuma commented on a change in pull request #9067: MINOR: Streams integration tests should not call exit

2020-07-27 Thread GitBox
ijuma commented on a change in pull request #9067: URL: https://github.com/apache/kafka/pull/9067#discussion_r460714731 ## File path: tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java ## @@ -241,7 +240,7 @@ public static VerifiableProducer createFromArgs(Argum

[GitHub] [kafka] ijuma commented on a change in pull request #9067: MINOR: Streams integration tests should not call exit

2020-07-27 Thread GitBox
ijuma commented on a change in pull request #9067: URL: https://github.com/apache/kafka/pull/9067#discussion_r460714731 ## File path: tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java ## @@ -241,7 +240,7 @@ public static VerifiableProducer createFromArgs(Argum

[GitHub] [kafka] ijuma commented on a change in pull request #9067: MINOR: Streams integration tests should not call exit

2020-07-27 Thread GitBox
ijuma commented on a change in pull request #9067: URL: https://github.com/apache/kafka/pull/9067#discussion_r460714731 ## File path: tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java ## @@ -241,7 +240,7 @@ public static VerifiableProducer createFromArgs(Argum

[GitHub] [kafka] ijuma commented on pull request #8936: KAFKA-10207: Fixed padded timeindex causing premature data deletion

2020-07-27 Thread GitBox
ijuma commented on pull request #8936: URL: https://github.com/apache/kafka/pull/8936#issuecomment-664201898 ok to test This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [kafka] ijuma commented on pull request #8936: KAFKA-10207: Fixed padded timeindex causing premature data deletion

2020-07-27 Thread GitBox
ijuma commented on pull request #8936: URL: https://github.com/apache/kafka/pull/8936#issuecomment-664203022 It would be useful to provide a summary of where we are with this. Do we have a consensus on what's needed to get this to a state where it can be merged? --

[GitHub] [kafka] ijuma commented on pull request #9082: MINOR: Update dependencies for Kafka 2.7 (part 1)

2020-07-27 Thread GitBox
ijuma commented on pull request #9082: URL: https://github.com/apache/kafka/pull/9082#issuecomment-664234424 Two builds passed, one had one failure due to existing flaky test: ``` org.apache.kafka.connect.mirror.MirrorConnectorsIntegrationTest > testOneWayReplicationWithAutorOffse

[GitHub] [kafka] cadonna commented on pull request #9066: KAFKA-10287: Skip unknown offsets when computing sum of changelog offsets

2020-07-27 Thread GitBox
cadonna commented on pull request #9066: URL: https://github.com/apache/kafka/pull/9066#issuecomment-664235920 Java 8 was aborted due to a timeout. ``` 04:56:02 Build timed out (after 270 minutes). Marking the build as aborted. ``` -

[GitHub] [kafka] cadonna commented on pull request #9066: KAFKA-10287: Skip unknown offsets when computing sum of changelog offsets

2020-07-27 Thread GitBox
cadonna commented on pull request #9066: URL: https://github.com/apache/kafka/pull/9066#issuecomment-664237012 @chia7712 Please do trigger Jenkins in the future. The more we have that have permission to trigger Jenkins and do it, the better it is. Especially for people like me that do not

[GitHub] [kafka] chia7712 commented on pull request #9066: KAFKA-10287: Skip unknown offsets when computing sum of changelog offsets

2020-07-27 Thread GitBox
chia7712 commented on pull request #9066: URL: https://github.com/apache/kafka/pull/9066#issuecomment-664238134 > Please do trigger Jenkins in the future. Copy that. Let me do it at once. Test this please This is an au

[GitHub] [kafka] viktorsomogyi commented on a change in pull request #4090: [KAFKA-6084] Propagate JSON parsing errors in ReassignPartitionsCommand

2020-07-27 Thread GitBox
viktorsomogyi commented on a change in pull request #4090: URL: https://github.com/apache/kafka/pull/4090#discussion_r460781660 ## File path: core/src/test/scala/unit/kafka/utils/JsonTest.scala ## @@ -41,14 +42,23 @@ class JsonTest { val jnf = JsonNodeFactory.instance

[GitHub] [kafka] viktorsomogyi commented on a change in pull request #4090: [KAFKA-6084] Propagate JSON parsing errors in ReassignPartitionsCommand

2020-07-27 Thread GitBox
viktorsomogyi commented on a change in pull request #4090: URL: https://github.com/apache/kafka/pull/4090#discussion_r460781753 ## File path: core/src/test/scala/unit/kafka/admin/ReassignPartitionsUnitTest.scala ## @@ -30,7 +30,7 @@ import org.apache.kafka.common.{Node, TopicPa

[GitHub] [kafka] ijuma commented on pull request #4090: [KAFKA-6084] Propagate JSON parsing errors in ReassignPartitionsCommand

2020-07-27 Thread GitBox
ijuma commented on pull request #4090: URL: https://github.com/apache/kafka/pull/4090#issuecomment-664265438 ok to test This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [kafka] ijuma merged pull request #9082: MINOR: Update dependencies for Kafka 2.7 (part 1)

2020-07-27 Thread GitBox
ijuma merged pull request #9082: URL: https://github.com/apache/kafka/pull/9082 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Created] (KAFKA-10313) Out of range offset errors leading to offset reset

2020-07-27 Thread Varsha Abhinandan (Jira)
Varsha Abhinandan created KAFKA-10313: - Summary: Out of range offset errors leading to offset reset Key: KAFKA-10313 URL: https://issues.apache.org/jira/browse/KAFKA-10313 Project: Kafka

[jira] [Updated] (KAFKA-10313) Out of range offset errors leading to offset reset

2020-07-27 Thread Varsha Abhinandan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Varsha Abhinandan updated KAFKA-10313: -- Description: Hi,   We have been occasionally noticing offset resets happening on the

[jira] [Updated] (KAFKA-10313) Out of range offset errors leading to offset reset

2020-07-27 Thread Varsha Abhinandan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Varsha Abhinandan updated KAFKA-10313: -- Description: Hi,   We have been occasionally noticing offset resets happening on the

[jira] [Updated] (KAFKA-10313) Out of range offset errors leading to offset reset

2020-07-27 Thread Varsha Abhinandan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Varsha Abhinandan updated KAFKA-10313: -- Priority: Critical (was: Major) > Out of range offset errors leading to offset reset

[jira] [Updated] (KAFKA-10313) Out of range offset errors leading to offset reset

2020-07-27 Thread Varsha Abhinandan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Varsha Abhinandan updated KAFKA-10313: -- Priority: Major (was: Minor) > Out of range offset errors leading to offset reset > -

[jira] [Updated] (KAFKA-10313) Out of range offset errors leading to offset reset

2020-07-27 Thread Varsha Abhinandan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Varsha Abhinandan updated KAFKA-10313: -- Priority: Minor (was: Critical) > Out of range offset errors leading to offset reset

[jira] [Updated] (KAFKA-10313) Out of range offset errors leading to offset reset

2020-07-27 Thread Varsha Abhinandan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Varsha Abhinandan updated KAFKA-10313: -- Description: Hi,   We have been occasionally noticing offset resets happening on the

[jira] [Commented] (KAFKA-9013) Flaky Test MirrorConnectorsIntegrationTest#testReplication

2020-07-27 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165743#comment-17165743 ] Bruno Cadonna commented on KAFKA-9013: -- https://builds.apache.org/job/kafka-pr-jdk11

[jira] [Commented] (KAFKA-9013) Flaky Test MirrorConnectorsIntegrationTest#testReplication

2020-07-27 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165744#comment-17165744 ] Bruno Cadonna commented on KAFKA-9013: -- https://builds.apache.org/job/kafka-pr-jdk14

[jira] [Issue Comment Deleted] (KAFKA-9013) Flaky Test MirrorConnectorsIntegrationTest#testReplication

2020-07-27 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-9013: - Comment: was deleted (was: https://builds.apache.org/job/kafka-pr-jdk14-scala2.13/1714 {code:jav

[jira] [Created] (KAFKA-10314) KafkaStorageException on reassignment when offline log directories exist

2020-07-27 Thread Noa Resare (Jira)
Noa Resare created KAFKA-10314: -- Summary: KafkaStorageException on reassignment when offline log directories exist Key: KAFKA-10314 URL: https://issues.apache.org/jira/browse/KAFKA-10314 Project: Kafka

[jira] [Assigned] (KAFKA-10312) MetadataCache.getPartitionMetadata may return incorrect error code when partition's leader is not present at the MetadataCache

2020-07-27 Thread Raman Verma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Verma reassigned KAFKA-10312: --- Assignee: Raman Verma > MetadataCache.getPartitionMetadata may return incorrect error code

[jira] [Commented] (KAFKA-10226) KStream without SASL information should return error in confluent cloud

2020-07-27 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165880#comment-17165880 ] John Roesler commented on KAFKA-10226: -- Hello [~wdaehn], It's been a little while

[jira] [Commented] (KAFKA-10301) Partition#remoteReplicasMap can be empty in certain race conditions

2020-07-27 Thread Randall Hauch (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165887#comment-17165887 ] Randall Hauch commented on KAFKA-10301: --- Thanks, [~enether]. I agree it's good to

[jira] [Commented] (KAFKA-10284) Group membership update due to static member rejoin should be persisted

2020-07-27 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165892#comment-17165892 ] Jason Gustafson commented on KAFKA-10284: - Hmm.. Not totally sure I buy this: >

[jira] [Comment Edited] (KAFKA-10284) Group membership update due to static member rejoin should be persisted

2020-07-27 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165892#comment-17165892 ] Jason Gustafson edited comment on KAFKA-10284 at 7/27/20, 6:13 PM: ---

[jira] [Assigned] (KAFKA-10224) The license term about jersey is not correct

2020-07-27 Thread Rens Groothuijsen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rens Groothuijsen reassigned KAFKA-10224: - Assignee: Rens Groothuijsen > The license term about jersey is not correct > --

[jira] [Created] (KAFKA-10315) Consider to throw exception for failed fetch requests

2020-07-27 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-10315: --- Summary: Consider to throw exception for failed fetch requests Key: KAFKA-10315 URL: https://issues.apache.org/jira/browse/KAFKA-10315 Project: Kafka I

[jira] [Updated] (KAFKA-10315) Consider to throw exception for failed fetch requests

2020-07-27 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10315: Issue Type: New Feature (was: Improvement) > Consider to throw exception for failed fetch

[jira] [Updated] (KAFKA-10315) Consider to throw exception for failed fetch requests

2020-07-27 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10315: Component/s: (was: clients) consumer > Consider to throw exception fo

[jira] [Commented] (KAFKA-10309) KafkaProducer's sendOffsetsToTransaction should not block infinitively

2020-07-27 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166022#comment-17166022 ] Guozhang Wang commented on KAFKA-10309: --- Thanks for catching this. I'd agree that

[jira] [Commented] (KAFKA-10134) High CPU issue during rebalance in Kafka consumer after upgrading to 2.5

2020-07-27 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166038#comment-17166038 ] Guozhang Wang commented on KAFKA-10134: --- What I did not see from my local run is t

[jira] [Created] (KAFKA-10316) Consider renaming getter method for Interactive Queries

2020-07-27 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-10316: --- Summary: Consider renaming getter method for Interactive Queries Key: KAFKA-10316 URL: https://issues.apache.org/jira/browse/KAFKA-10316 Project: Kafka

[jira] [Commented] (KAFKA-7878) Connect Task already exists in this worker when failed to create consumer

2020-07-27 Thread Nitika Raj (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166089#comment-17166089 ] Nitika Raj commented on KAFKA-7878: --- We faced similar problems but then tracking back i

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

2020-07-27 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166090#comment-17166090 ] Guozhang Wang commented on KAFKA-8037: -- Thank you all for providing your thoughts! I

[jira] [Assigned] (KAFKA-10315) Consider to throw exception for failed fetch requests

2020-07-27 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-10315: - Assignee: Luke Chen > Consider to throw exception for failed fetch requests > -

[jira] [Created] (KAFKA-10317) Global thread should honor shutdown signal during bootstrapping

2020-07-27 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-10317: --- Summary: Global thread should honor shutdown signal during bootstrapping Key: KAFKA-10317 URL: https://issues.apache.org/jira/browse/KAFKA-10317 Project: Kafka

[jira] [Updated] (KAFKA-7380) Global thread restore blocks KafkaStreams#start()

2020-07-27 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7380: --- Issue Type: Improvement (was: Bug) > Global thread restore blocks KafkaStreams#start() > ---

[jira] [Assigned] (KAFKA-10317) Global thread should honor shutdown signal during bootstrapping

2020-07-27 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-10317: --- Assignee: Matthias J. Sax > Global thread should honor shutdown signal during boots

[jira] [Commented] (KAFKA-7380) Global thread restore blocks KafkaStreams#start()

2020-07-27 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166131#comment-17166131 ] Matthias J. Sax commented on KAFKA-7380: [~Yohan123] – I am working on some relat

[jira] [Commented] (KAFKA-10316) Consider renaming getter method for Interactive Queries

2020-07-27 Thread John Thomas (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166136#comment-17166136 ] John Thomas commented on KAFKA-10316: - [~mjsax] Can I pick this up ?  * I understan

[jira] [Commented] (KAFKA-10315) Consider to throw exception for failed fetch requests

2020-07-27 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166138#comment-17166138 ] Matthias J. Sax commented on KAFKA-10315: - [~showuon] thanks for you interest in

[jira] [Commented] (KAFKA-10316) Consider renaming getter method for Interactive Queries

2020-07-27 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166142#comment-17166142 ] Matthias J. Sax commented on KAFKA-10316: - Sure, feel free to pick it up. Your u

[jira] [Commented] (KAFKA-10315) Consider to throw exception for failed fetch requests

2020-07-27 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166146#comment-17166146 ] Luke Chen commented on KAFKA-10315: --- [~mjsax], Thanks for reminding. I'll wait and see

[jira] [Commented] (KAFKA-10316) Consider renaming getter method for Interactive Queries

2020-07-27 Thread John Thomas (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166149#comment-17166149 ] John Thomas commented on KAFKA-10316: - Thanks Matt. I've requested access to create

[jira] [Commented] (KAFKA-10309) KafkaProducer's sendOffsetsToTransaction should not block infinitively

2020-07-27 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166151#comment-17166151 ] Boyang Chen commented on KAFKA-10309: - Sounds good. > KafkaProducer's sendOffsetsTo