[jira] [Created] (KAFKA-13176) frequent ISR shrinks and expansion with default num.replica.fetchers (1) under very low throughput conditions.

2021-08-08 Thread kaushik srinivas (Jira)
kaushik srinivas created KAFKA-13176: Summary: frequent ISR shrinks and expansion with default num.replica.fetchers (1) under very low throughput conditions. Key: KAFKA-13176 URL: https://issues.apache.org/jir

[jira] [Created] (KAFKA-13177) partition failures and fewer shrink but a lot of isr expansions with increased num.replica.fetchers in kafka brokers

2021-08-08 Thread kaushik srinivas (Jira)
kaushik srinivas created KAFKA-13177: Summary: partition failures and fewer shrink but a lot of isr expansions with increased num.replica.fetchers in kafka brokers Key: KAFKA-13177 URL: https://issues.apache.o

[jira] [Created] (KAFKA-13178) frequent network_exception trace at kafka producer.

2021-08-08 Thread kaushik srinivas (Jira)
kaushik srinivas created KAFKA-13178: Summary: frequent network_exception trace at kafka producer. Key: KAFKA-13178 URL: https://issues.apache.org/jira/browse/KAFKA-13178 Project: Kafka I

[GitHub] [kafka] showuon opened a new pull request #11188: KAFKA-13021: disallow grace called after grace set via new API

2021-08-08 Thread GitBox
showuon opened a new pull request #11188: URL: https://github.com/apache/kafka/pull/11188 Saw this `TODO` comment while tracing codes. Add the check to disallow grace called after grace set via new API, and add tests for them. ### Committer Checklist (excluded from commit message)

[GitHub] [kafka] showuon commented on pull request #11188: KAFKA-13021: disallow grace called after grace set via new API

2021-08-08 Thread GitBox
showuon commented on pull request #11188: URL: https://github.com/apache/kafka/pull/11188#issuecomment-894762289 @ableegoldman , please take a look. Thank you. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

[jira] [Updated] (KAFKA-5966) Support ByteBuffer serialization in Kafka Streams

2021-08-08 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-5966: - Description: context: https://github.com/apache/kafka/pull/3027/files#r117378317   Currently Kafka Stre

[GitHub] [kafka] showuon edited a comment on pull request #11187: [WIP] KAFKA-5966: let CacheFunction#key return ByteBuffer

2021-08-08 Thread GitBox
showuon edited a comment on pull request #11187: URL: https://github.com/apache/kafka/pull/11187#issuecomment-894739236 @xvrl @guozhangwang , could you help take a look and make sure I'm on the right way? I know in KAFKA-5966, we expected to support for serdes into/from `ByteBuffer` in str

[GitHub] [kafka] showuon commented on pull request #11188: KAFKA-13021: disallow grace called after grace set via new API

2021-08-08 Thread GitBox
showuon commented on pull request #11188: URL: https://github.com/apache/kafka/pull/11188#issuecomment-894925469 Failed test is not related. ``` Build / JDK 16 and Scala 2.13 / org.apache.kafka.streams.integration.StoreQueryIntegrationTest.shouldQueryStoresAfterAddingAndRemovingStrea

[GitHub] [kafka] showuon commented on pull request #11124: KAFKA-12839: Let SlidingWindows aggregation support window size of 0

2021-08-08 Thread GitBox
showuon commented on pull request #11124: URL: https://github.com/apache/kafka/pull/11124#issuecomment-894973913 @mjsax , as discussed, I've created a `SlidingWindow` for `SlidingWindows` aggregation. So we can support window size of 0 in SlidingWindows now. But there's still a issu

[jira] [Comment Edited] (KAFKA-13163) Issue with MySql worker sink connector

2021-08-08 Thread Muddam Pullaiah Yadav (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395853#comment-17395853 ] Muddam Pullaiah Yadav edited comment on KAFKA-13163 at 8/9/21, 6:48 AM: --

[jira] [Commented] (KAFKA-13163) Issue with MySql worker sink connector

2021-08-08 Thread Muddam Pullaiah Yadav (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395853#comment-17395853 ] Muddam Pullaiah Yadav commented on KAFKA-13163: --- Hi [~cricket007] @[Robin

[jira] [Commented] (KAFKA-13163) Issue with MySql worker sink connector

2021-08-08 Thread Muddam Pullaiah Yadav (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395854#comment-17395854 ] Muddam Pullaiah Yadav commented on KAFKA-13163: --- and this is my message \{

[jira] [Updated] (KAFKA-13163) MySQL Sink Connector - JsonConverter - DataException: Unknown schema type: null

2021-08-08 Thread Muddam Pullaiah Yadav (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Muddam Pullaiah Yadav updated KAFKA-13163: -- Summary: MySQL Sink Connector - JsonConverter - DataException: Unknown schema