[jira] [Created] (KAFKA-6992) Configuring the batch.size to zero won't disable the batching entirely

Chia-Ping Tsai created KAFKA-6992: - Summary: Configuring the batch.size to zero won't disable the batching entirely Key: KAFKA-6992 URL: https://issues.apache.org/jira/browse/KAFKA-6992 Project: Kafka

[jira] [Commented] (KAFKA-6959) Any impact we foresee if we upgrade Linux version or move to VM instead of physical Linux server

[ https://issues.apache.org/jira/browse/KAFKA-6959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501345#comment-16501345 ] Gene Yi commented on KAFKA-6959: cool thanks [~omkreddy] ! > Any impact we foresee if we

[jira] [Commented] (KAFKA-6986) Export Admin Client metrics through Stream Threads

[ https://issues.apache.org/jira/browse/KAFKA-6986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501300#comment-16501300 ] Shun Guan commented on KAFKA-6986: -- If nobody is claiming this, can someone assign this

[jira] [Commented] (KAFKA-6991) Connect Rest Extension Plugin issue with Class Loader

[ https://issues.apache.org/jira/browse/KAFKA-6991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501299#comment-16501299 ] ASF GitHub Bot commented on KAFKA-6991: --- mageshn opened a new pull request #5135: K

[jira] [Created] (KAFKA-6991) Connect Rest Extension Plugin issue with Class Loader

Magesh kumar Nandakumar created KAFKA-6991: -- Summary: Connect Rest Extension Plugin issue with Class Loader Key: KAFKA-6991 URL: https://issues.apache.org/jira/browse/KAFKA-6991 Project: Kafka

[jira] [Updated] (KAFKA-6989) Support Async Processing in Streams

[ https://issues.apache.org/jira/browse/KAFKA-6989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6989: --- Labels: needs-kip (was: ) > Support Async Processing in Streams > --

[jira] [Updated] (KAFKA-6986) Export Admin Client metrics through Stream Threads

[ https://issues.apache.org/jira/browse/KAFKA-6986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6986: --- Component/s: streams > Export Admin Client metrics through Stream Threads > -

[jira] [Updated] (KAFKA-6986) Export Admin Client metrics through Stream Threads

[ https://issues.apache.org/jira/browse/KAFKA-6986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6986: --- Labels: Newcomer beginner newbie (was: Newcomer newbie streams) > Export Admin Client metric

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

[ https://issues.apache.org/jira/browse/KAFKA-6841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1650#comment-1650 ] ASF GitHub Bot commented on KAFKA-6841: --- piyushvijay closed pull request #5079: KAF

[jira] [Updated] (KAFKA-6963) KIP-308: Add a Kafka Source Connector to Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-6963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rhys Anthony McCaig updated KAFKA-6963: --- Description: This proposal introduces a new Kafka Connect Source Connector. See the

[jira] [Commented] (KAFKA-6990) CommitFailedException; this task may be no longer owned by the thread

[ https://issues.apache.org/jira/browse/KAFKA-6990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501100#comment-16501100 ] Eugen Feller commented on KAFKA-6990: - I have also noticed a lot messages like this i

[jira] [Commented] (KAFKA-6722) SensorAccess.getOrCreate should be more efficient

[ https://issues.apache.org/jira/browse/KAFKA-6722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501095#comment-16501095 ] ASF GitHub Bot commented on KAFKA-6722: --- wuqingjun closed pull request #5109: KAFKA

[jira] [Commented] (KAFKA-6986) Export Admin Client metrics through Stream Threads

[ https://issues.apache.org/jira/browse/KAFKA-6986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500984#comment-16500984 ] Shun Guan commented on KAFKA-6986: -- Hi, I am a new contributor, do you mind if I take a

[jira] [Resolved] (KAFKA-5632) Message headers not supported by Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-5632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5632. -- Resolution: Duplicate > Message headers not supported by Kafka Streams > --

[jira] [Commented] (KAFKA-5632) Message headers not supported by Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-5632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500981#comment-16500981 ] Guozhang Wang commented on KAFKA-5632: -- As of KIP-244 (release 2.0) we have added he

[jira] [Resolved] (KAFKA-6938) Add documentation for accessing Headers on Kafka Streams Processor API

[ https://issues.apache.org/jira/browse/KAFKA-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6938. -- Resolution: Fixed > Add documentation for accessing Headers on Kafka Streams Processor API > --

[jira] [Commented] (KAFKA-6938) Add documentation for accessing Headers on Kafka Streams Processor API

[ https://issues.apache.org/jira/browse/KAFKA-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500970#comment-16500970 ] ASF GitHub Bot commented on KAFKA-6938: --- guozhangwang closed pull request #5128: KA

[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&focusedCommentId=16500961#comment-16500961 ] ASF GitHub Bot commented on KAFKA-6813: --- guozhangwang closed pull request #5075: KA

[jira] [Updated] (KAFKA-6977) Kafka Streams - java.lang.IllegalStateException: Unexpected error code 2 while fetching data

[ https://issues.apache.org/jira/browse/KAFKA-6977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugen Feller updated KAFKA-6977: Affects Version/s: (was: 0.10.2.1) 0.11.0.1 > Kafka Streams - java.lang

[jira] [Updated] (KAFKA-6990) CommitFailedException; this task may be no longer owned by the thread

[ https://issues.apache.org/jira/browse/KAFKA-6990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugen Feller updated KAFKA-6990: Affects Version/s: (was: 0.10.2.1) 0.11.0.1 > CommitFailedException; thi

[jira] [Updated] (KAFKA-6990) CommitFailedException; this task may be no longer owned by the thread

[ https://issues.apache.org/jira/browse/KAFKA-6990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugen Feller updated KAFKA-6990: Description: We are seeing a lot of CommitFailedExceptions on one of our Kafka stream apps. Runnin

[jira] [Commented] (KAFKA-5919) Adding checks on "version" field for tools using it

[ https://issues.apache.org/jira/browse/KAFKA-5919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500879#comment-16500879 ] ASF GitHub Bot commented on KAFKA-5919: --- lindong28 closed pull request #5126: KAFKA

[jira] [Updated] (KAFKA-6990) CommitFailedException; this task may be no longer owned by the thread

[ https://issues.apache.org/jira/browse/KAFKA-6990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugen Feller updated KAFKA-6990: Description: We are seeing a lot of CommitFailedExceptions on one of our Kafka stream apps. Runnin

[jira] [Updated] (KAFKA-6990) CommitFailedException; this task may be no longer owned by the thread

[ https://issues.apache.org/jira/browse/KAFKA-6990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugen Feller updated KAFKA-6990: Description: We are seeing a lot of CommitFailedExceptions on one of our Kafka stream apps. Runnin

[jira] [Created] (KAFKA-6990) CommitFailedException; this task may be no longer owned by the thread

Eugen Feller created KAFKA-6990: --- Summary: CommitFailedException; this task may be no longer owned by the thread Key: KAFKA-6990 URL: https://issues.apache.org/jira/browse/KAFKA-6990 Project: Kafka

[jira] [Commented] (KAFKA-6975) AdminClient.deleteRecords() may cause replicas unable to fetch from beginning

[ https://issues.apache.org/jira/browse/KAFKA-6975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500796#comment-16500796 ] ASF GitHub Bot commented on KAFKA-6975: --- apovzner opened a new pull request #5133:

[jira] [Commented] (KAFKA-5098) KafkaProducer.send() blocks and generates TimeoutException if topic name has illegal char

[ https://issues.apache.org/jira/browse/KAFKA-5098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500755#comment-16500755 ] Joel Koshy commented on KAFKA-5098: --- [~huxi_2b] are you still working on this? If not,

[jira] [Commented] (KAFKA-6987) Reimplement KafkaFuture with CopletableFuture

[ https://issues.apache.org/jira/browse/KAFKA-6987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500655#comment-16500655 ] ASF GitHub Bot commented on KAFKA-6987: --- andrasbeni opened a new pull request #5131

[jira] [Comment Edited] (KAFKA-6989) Support Async Processing in Streams

[ https://issues.apache.org/jira/browse/KAFKA-6989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500596#comment-16500596 ] Virgil Palanciuc edited comment on KAFKA-6989 at 6/4/18 5:48 PM: --

[jira] [Commented] (KAFKA-6989) Support Async Processing in Streams

[ https://issues.apache.org/jira/browse/KAFKA-6989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500596#comment-16500596 ] Virgil Palanciuc commented on KAFKA-6989: - It seems to me that option 2 is a fals

[jira] [Commented] (KAFKA-4690) IllegalStateException using DeleteTopicsRequest when delete.topic.enable=false

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

[jira] [Commented] (KAFKA-6281) Kafka JavaAPI Producer failed with NotLeaderForPartitionException

[ https://issues.apache.org/jira/browse/KAFKA-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500542#comment-16500542 ] Anil commented on KAFKA-6281: - For my topic, leader is node 1.  During the same time I got th

[jira] [Commented] (KAFKA-6281) Kafka JavaAPI Producer failed with NotLeaderForPartitionException

[ https://issues.apache.org/jira/browse/KAFKA-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500540#comment-16500540 ] Manikumar commented on KAFKA-6281: -- Can you upload server logs and server.properties? >

[jira] [Created] (KAFKA-6989) Support Async Processing in Streams

Guozhang Wang created KAFKA-6989: Summary: Support Async Processing in Streams Key: KAFKA-6989 URL: https://issues.apache.org/jira/browse/KAFKA-6989 Project: Kafka Issue Type: Improvement

[jira] [Comment Edited] (KAFKA-6281) Kafka JavaAPI Producer failed with NotLeaderForPartitionException

[ https://issues.apache.org/jira/browse/KAFKA-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500528#comment-16500528 ] Anil edited comment on KAFKA-6281 at 6/4/18 5:10 PM: - Thanks [~omkred

[jira] [Reopened] (KAFKA-6281) Kafka JavaAPI Producer failed with NotLeaderForPartitionException

[ https://issues.apache.org/jira/browse/KAFKA-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anil reopened KAFKA-6281: - Thanks [~omkreddy],  We've got this issue again today, twice.  I see that both the times, there is GC running in my

[jira] [Commented] (KAFKA-5761) Serializer API should support ByteBuffer

[ https://issues.apache.org/jira/browse/KAFKA-5761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500347#comment-16500347 ] Chia-Ping Tsai commented on KAFKA-5761: --- +1(non-binding) to this idea(if the ByteBu

[jira] [Created] (KAFKA-6988) Kafka windows classpath too long

lkgen created KAFKA-6988: Summary: Kafka windows classpath too long Key: KAFKA-6988 URL: https://issues.apache.org/jira/browse/KAFKA-6988 Project: Kafka Issue Type: Bug Components: core

[jira] [Commented] (KAFKA-6923) Consolidate ExtendedSerializer/Serializer and ExtendedDeserializer/Deserializer

[ https://issues.apache.org/jira/browse/KAFKA-6923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500291#comment-16500291 ] Viktor Somogyi commented on KAFKA-6923: --- [~ijuma] just wanted to give a heads up th

[jira] [Assigned] (KAFKA-6883) KafkaShortnamer should allow to convert Kerberos principal name to upper case user name

[ https://issues.apache.org/jira/browse/KAFKA-6883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-6883: Assignee: Manikumar > KafkaShortnamer should allow to convert Kerberos principal name to upper cas

[jira] [Commented] (KAFKA-6952) LogCleaner stopped due to org.apache.kafka.common.errors.CorruptRecordException

[ https://issues.apache.org/jira/browse/KAFKA-6952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499984#comment-16499984 ] huxihx commented on KAFKA-6952: --- Could you offer the value of config `log.message.format.ve

[jira] [Commented] (KAFKA-6976) Kafka Streams instances going in to DEAD state

[ https://issues.apache.org/jira/browse/KAFKA-6976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499964#comment-16499964 ] Ashish Surana commented on KAFKA-6976: -- Hi Matthias, any clue here why is this happe

[jira] [Commented] (KAFKA-6984) Question

[ https://issues.apache.org/jira/browse/KAFKA-6984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499875#comment-16499875 ] darion yaphet commented on KAFKA-6984: -- please make sure directory is right . > Qu

[jira] [Created] (KAFKA-6987) Reimplement KafkaFuture with CopletableFuture

Andras Beni created KAFKA-6987: -- Summary: Reimplement KafkaFuture with CopletableFuture Key: KAFKA-6987 URL: https://issues.apache.org/jira/browse/KAFKA-6987 Project: Kafka Issue Type: Improveme