jira  

Messages by Thread

• [jira] [Assigned] (KAFKA-6616) kafka-merge-pr.py should use GitHub's REST API to merge Viktor Popov (JIRA)
• [jira] [Created] (KAFKA-6950) Add mechanism to delay response to failed client authentication Dhruvil Shah (JIRA)
• [jira] [Updated] (KAFKA-6950) Add mechanism to delay response to failed client authentication Dhruvil Shah (JIRA)
• [jira] [Commented] (KAFKA-6811) Tasks should have access to connector and task metadata Sandeep Tamhankar (JIRA)
• [jira] [Resolved] (KAFKA-3649) Add capability to query broker process for configuration properties Manikumar (JIRA)
• [jira] [Resolved] (KAFKA-6921) Remove old Scala producer and all related code, tests, and tools Manikumar (JIRA)
• [jira] [Assigned] (KAFKA-6949) NoSuchElementException in ReplicaManager Dong Lin (JIRA)
• [jira] [Commented] (KAFKA-6949) NoSuchElementException in ReplicaManager Jason Gustafson (JIRA)
  • [jira] [Commented] (KAFKA-6949) NoSuchElementException in ReplicaManager Dong Lin (JIRA)
• [jira] [Created] (KAFKA-6949) NoSuchElementException in ReplicaManager Jason Gustafson (JIRA)
• [jira] [Resolved] (KAFKA-6907) Not able to delete topic praveen (JIRA)
• [jira] [Updated] (KAFKA-6942) Connect connectors api doesn't show versions of connectors Randall Hauch (JIRA)
• [jira] [Updated] (KAFKA-6943) Have option to shutdown KS cleanly if any threads crashes, or if all threads crash Antony Stubbs (JIRA)
  • [jira] [Updated] (KAFKA-6943) Have option to shutdown KS cleanly if any threads crashes, or if all threads crash Antony Stubbs (JIRA)
• [jira] [Comment Edited] (KAFKA-6943) Have option to shutdown KS cleanly if any task crashes, or if all tasks crash Antony Stubbs (JIRA)
• [jira] [Commented] (KAFKA-6668) Broker crashes on restart ,got a CorruptRecordException: Record size is smaller than minimum record overhead(14) evan einst (JIRA)
• [jira] [Commented] (KAFKA-6948) Avoid overflow in timestamp comparison ASF GitHub Bot (JIRA)
• [jira] [Created] (KAFKA-6948) Avoid overflow in timestamp comparison Giovanni Liva (JIRA)
• [jira] [Updated] (KAFKA-6947) Mirrormaker Closing producer due to send failure Andrew Holford (JIRA)
  • [jira] [Updated] (KAFKA-6947) Mirrormaker Closing producer due to send failure Andrew Holford (JIRA)
• [jira] [Created] (KAFKA-6947) Mirrormaker Closing producer due to send failure Andrew Holford (JIRA)
• [jira] [Resolved] (KAFKA-2061) Offer a --version flag to print the kafka version Jason Gustafson (JIRA)
• [jira] [Commented] (KAFKA-2061) Offer a --version flag to print the kafka version ASF GitHub Bot (JIRA)
• [jira] [Comment Edited] (KAFKA-6898) org.apache.kafka.common.errors.TimeoutException huxihx (JIRA)
• [jira] [Resolved] (KAFKA-6911) Incorrect check for keystore/truststore dynamic update Jason Gustafson (JIRA)
• [jira] [Updated] (KAFKA-6946) Keep the session id for incremental fetch when fetch responses are throttled Jon Lee (JIRA)
• [jira] [Created] (KAFKA-6946) Keep the fetch session id for incremental fetch when Jon Lee (JIRA)
• [jira] [Created] (KAFKA-6945) Add support to allow users to acquire delegation tokens for other users Manikumar (JIRA)
• [jira] [Created] (KAFKA-6944) Add system tests testing the new throttling behavior using older clients/brokers Jon Lee (JIRA)
• [jira] [Updated] (KAFKA-4628) Support KTable/GlobalKTable Joins Guozhang Wang (JIRA)
• [jira] [Commented] (KAFKA-6943) Have option to shutdown KS cleanly if any task crashes, or if all tasks crash Guozhang Wang (JIRA)
  • [jira] [Commented] (KAFKA-6943) Have option to shutdown KS cleanly if any task crashes, or if all tasks crash Antony Stubbs (JIRA)
• [jira] [Resolved] (KAFKA-6862) test toolchain Manikumar (JIRA)
• [jira] [Assigned] (KAFKA-4217) KStream.transform equivalent of flatMap Matthias J. Sax (JIRA)
• [jira] [Assigned] (KAFKA-6925) Memory leak in org.apache.kafka.streams.processor.internals.StreamThread$StreamsMetricsThreadImpl John Roesler (JIRA)
• [jira] [Updated] (KAFKA-6940) Kafka Cluster and Zookeeper ensemble configuration with SASL authentication Randall Hauch (JIRA)
• [jira] [Created] (KAFKA-6943) Have option to shutdown KS cleanly if any task crashes, or if all tasks crash Antony Stubbs (JIRA)
• [jira] [Created] (KAFKA-6942) Connect connectors api doesn't show versions of connectors Antony Stubbs (JIRA)
• [jira] [Resolved] (KAFKA-4505) Cannot get topic lag since kafka upgrade from 0.8.1.0 to 0.10.1.0 Manikumar (JIRA)
• [jira] [Commented] (KAFKA-6616) kafka-merge-pr.py should use GitHub's REST API to merge Viktor Popov (JIRA)
  • [jira] [Commented] (KAFKA-6616) kafka-merge-pr.py should use GitHub's REST API to merge Ismael Juma (JIRA)
• [jira] [Resolved] (KAFKA-2036) Consumer and broker have different networks Manikumar (JIRA)
• [jira] [Resolved] (KAFKA-3793) Kafka Python Consumer library messages gets truncated Manikumar (JIRA)
• [jira] [Commented] (KAFKA-6941) when passing port = 0 to worker, the advertisedPort still is 0 rather than a random port Chia-Ping Tsai (JIRA)
  • [jira] [Commented] (KAFKA-6941) when passing port = 0 to worker, the advertisedPort still is 0 rather than a random port Chia-Ping Tsai (JIRA)
  • [jira] [Commented] (KAFKA-6941) when passing port = 0 to worker, the advertisedPort still is 0 rather than a random port ASF GitHub Bot (JIRA)
• [jira] [Created] (KAFKA-6941) when passing port = 0 to worker, the advertisedPort still is 0 rather than a random port Chia-Ping Tsai (JIRA)
• [jira] [Commented] (KAFKA-5519) Support for multiple certificates in a single keystore sebastien diaz (JIRA)
• [jira] [Created] (KAFKA-6940) Kafka Cluster and Zookeeper ensemble configuration with SASL authentication Shashank Jain (JIRA)
• [jira] [Commented] (KAFKA-6936) Scala API Wrapper for Streams uses default serializer for table aggregate Guozhang Wang (JIRA)
  • [jira] [Commented] (KAFKA-6936) Scala API Wrapper for Streams uses default serializer for table aggregate Daniel Heinrich (JIRA)
• [jira] [Created] (KAFKA-6939) Change the default of log.message.timestamp.difference.max.ms to 500 years Badai Aqrandista (JIRA)
• [jira] [Updated] (KAFKA-6938) Add documentation for accessing Headers on Kafka Streams Processor API Matthias J. Sax (JIRA)
  • [jira] [Updated] (KAFKA-6938) Add documentation for accessing Headers on Kafka Streams Processor API Matthias J. Sax (JIRA)
  • [jira] [Updated] (KAFKA-6938) Add documentation for accessing Headers on Kafka Streams Processor API Matthias J. Sax (JIRA)
• [jira] [Created] (KAFKA-6938) Add documentation for accessing Headers on Kafka Streams Processor API Jorge Quilcate (JIRA)
• [jira] [Updated] (KAFKA-6937) In-sync replica delayed during fetch if replica throttle is exceeded Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-6937) In-sync replica delayed during fetch if replica throttle is exceeded Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-6937) In-sync replica delayed during fetch if replica throttle is exceeded Jun Rao (JIRA)
• [jira] [Commented] (KAFKA-6937) In-sync replica delayed during fetch if replica throttle is exceeded ASF GitHub Bot (JIRA)
• [jira] [Created] (KAFKA-6937) In-sync replica delayed during fetch if replica throttle is exceeded Jun Rao (JIRA)
• [jira] [Created] (KAFKA-6936) Scala API Wrapper for Streams uses default serializer for table aggregate Daniel Heinrich (JIRA)
• [jira] [Updated] (KAFKA-6935) KIP-295 Add Streams Config for Optional Optimization Matthias J. Sax (JIRA)
  • [jira] [Updated] (KAFKA-6935) KIP-295 Add Streams Config for Optional Optimization Matthias J. Sax (JIRA)
• [jira] [Resolved] (KAFKA-6356) UnknownTopicOrPartitionException & NotLeaderForPartitionException and log deletion happening with retention bytes kept at -1. Manikumar (JIRA)
• [jira] [Updated] (KAFKA-6776) Connect Rest Extension Plugin Magesh kumar Nandakumar (JIRA)
• [jira] [Commented] (KAFKA-6935) KIP-295 Add Streams Config for Optional Optimization ASF GitHub Bot (JIRA)
• [jira] [Created] (KAFKA-6935) KIP-295 Add Streams Config for Optional Optimization Bill Bejeck (JIRA)
• [jira] [Commented] (KAFKA-6933) Broker reports Corrupted index warnings apparently infinitely Ismael Juma (JIRA)
  • [jira] [Commented] (KAFKA-6933) Broker reports Corrupted index warnings apparently infinitely Franco Bonazza (JIRA)
  • [jira] [Commented] (KAFKA-6933) Broker reports Corrupted index warnings apparently infinitely Franco Bonazza (JIRA)
• [jira] [Updated] (KAFKA-6932) Avroconverter does not propagate subjectname stratergy Masthan Shaik (JIRA)
• [jira] [Commented] (KAFKA-6934) Csv reporter doesn't work for ConsoleConsumer Viktor Somogyi (JIRA)
• [jira] [Assigned] (KAFKA-6934) Csv reporter doesn't work for ConsoleConsumer Viktor Somogyi (JIRA)
• [jira] [Created] (KAFKA-6934) Csv reporter doesn't work for ConsoleConsumer Sandor Murakozi (JIRA)
• [jira] [Updated] (KAFKA-6933) Broker reports Corrupted index warnings apparently infinitely Franco Bonazza (JIRA)
• [jira] [Assigned] (KAFKA-6923) Consolidate ExtendedSerializer/Serializer and ExtendedDeserializer/Deserializer Viktor Somogyi (JIRA)
• [jira] [Commented] (KAFKA-4290) High CPU caused by timeout overflow in WorkerCoordinator ASF GitHub Bot (JIRA)
• [jira] [Created] (KAFKA-6933) Broker reports Corrupted index warnings apparently infinitely Franco Bonazza (JIRA)
• [jira] [Comment Edited] (KAFKA-6762) log-cleaner thread terminates due to java.lang.IllegalStateException Uwe Eisele (JIRA)
  • [jira] [Comment Edited] (KAFKA-6762) log-cleaner thread terminates due to java.lang.IllegalStateException Uwe Eisele (JIRA)
  • [jira] [Comment Edited] (KAFKA-6762) log-cleaner thread terminates due to java.lang.IllegalStateException Uwe Eisele (JIRA)
  • [jira] [Comment Edited] (KAFKA-6762) log-cleaner thread terminates due to java.lang.IllegalStateException Uwe Eisele (JIRA)
  • [jira] [Comment Edited] (KAFKA-6762) log-cleaner thread terminates due to java.lang.IllegalStateException Uwe Eisele (JIRA)
  • [jira] [Comment Edited] (KAFKA-6762) log-cleaner thread terminates due to java.lang.IllegalStateException Uwe Eisele (JIRA)
  • [jira] [Comment Edited] (KAFKA-6762) log-cleaner thread terminates due to java.lang.IllegalStateException Uwe Eisele (JIRA)
  • [jira] [Comment Edited] (KAFKA-6762) log-cleaner thread terminates due to java.lang.IllegalStateException Uwe Eisele (JIRA)
• [jira] [Commented] (KAFKA-4628) Support KTable/GlobalKTable Joins Adam Bellemare (JIRA)
  • [jira] [Commented] (KAFKA-4628) Support KTable/GlobalKTable Joins Adam Bellemare (JIRA)
  • [jira] [Commented] (KAFKA-4628) Support KTable/GlobalKTable Joins Guozhang Wang (JIRA)
• [jira] [Comment Edited] (KAFKA-6931) Make worker id configurable Chia-Ping Tsai (JIRA)
• [jira] [Created] (KAFKA-6932) Avroconverter does not propagate subjectname stratergy Masthan Shaik (JIRA)
• [jira] [Commented] (KAFKA-6914) Kafka Connect - Plugins class should have a constructor that can take in parent ClassLoader Ewen Cheslack-Postava (JIRA)
  • [jira] [Commented] (KAFKA-6914) Kafka Connect - Plugins class should have a constructor that can take in parent ClassLoader Sriram KS (JIRA)
• [jira] [Commented] (KAFKA-4559) Add a site search bar on the Web site ASF GitHub Bot (JIRA)
  • [jira] [Commented] (KAFKA-4559) Add a site search bar on the Web site Ravi Raj Singh (JIRA)
• [jira] [Commented] (KAFKA-6886) Externalize Secrets for Kafka Connect Configurations ASF GitHub Bot (JIRA)
• [jira] [Resolved] (KAFKA-6875) EosIntegrationTest#shouldNotViolateEosIfOneTaskFails is flaky Ted Yu (JIRA)
• [jira] [Resolved] (KAFKA-6920) Enhance ConsumerRecordFactory and OutputVerifier for Header support Matthias J. Sax (JIRA)
• [jira] [Issue Comment Deleted] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null Matthias J. Sax (JIRA)
• [jira] [Commented] (KAFKA-5807) Check Connector.config() and Transformation.config() returns a valid ConfigDef ASF GitHub Bot (JIRA)
• [jira] [Resolved] (KAFKA-5807) Check Connector.config() and Transformation.config() returns a valid ConfigDef Ewen Cheslack-Postava (JIRA)
• [jira] [Commented] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null ASF GitHub Bot (JIRA)
• [jira] [Resolved] (KAFKA-2943) Transient Failure in kafka.producer.SyncProducerTest.testReachableServer Manikumar (JIRA)
• [jira] [Resolved] (KAFKA-5432) producer and consumer SocketTimeoutException Manikumar (JIRA)
• [jira] [Resolved] (KAFKA-4419) Unable to GetOffset when the ACL of topic is defined Manikumar (JIRA)
• [jira] [Resolved] (KAFKA-1460) NoReplicaOnlineException: No replica for partition Manikumar (JIRA)
• [jira] [Updated] (KAFKA-3355) GetOffsetShell command doesn't work with SASL enabled Kafka Manikumar (JIRA)
• [jira] [Resolved] (KAFKA-2174) Wrong TopicMetadata deserialization Manikumar (JIRA)
• [jira] [Resolved] (KAFKA-3345) ProducerResponse could gracefully handle no throttle time provided Manikumar (JIRA)
• [jira] [Resolved] (KAFKA-5039) Logging in BlockingChannel and SyncProducer connect Manikumar (JIRA)
• [jira] [Resolved] (KAFKA-3246) Transient Failure in kafka.producer.SyncProducerTest.testProduceCorrectlyReceivesResponse Manikumar (JIRA)
• [jira] [Assigned] (KAFKA-4936) Allow dynamic routing of output records Matthias J. Sax (JIRA)
• [jira] [Commented] (KAFKA-6923) Consolidate ExtendedSerializer/Serializer and ExtendedDeserializer/Deserializer Viktor Somogyi (JIRA)
  • [jira] [Commented] (KAFKA-6923) Consolidate ExtendedSerializer/Serializer and ExtendedDeserializer/Deserializer Ismael Juma (JIRA)
  • [jira] [Commented] (KAFKA-6923) Consolidate ExtendedSerializer/Serializer and ExtendedDeserializer/Deserializer Viktor Somogyi (JIRA)
• [jira] [Resolved] (KAFKA-6924) Making state store queryable on replicas Guozhang Wang (JIRA)
• [jira] [Commented] (KAFKA-6931) Make worker id configurable Chia-Ping Tsai (JIRA)
  • [jira] [Commented] (KAFKA-6931) Make worker id configurable ASF GitHub Bot (JIRA)
• [jira] [Created] (KAFKA-6931) Make worker id configurable Chia-Ping Tsai (JIRA)
• [jira] [Updated] (KAFKA-6931) Make worker id configurable Chia-Ping Tsai (JIRA)
  • [jira] [Updated] (KAFKA-6931) Make worker id configurable Chia-Ping Tsai (JIRA)
  • [jira] [Updated] (KAFKA-6931) Make worker id configurable Chia-Ping Tsai (JIRA)
• [jira] [Commented] (KAFKA-2983) Remove old Scala consumer and all related code, tests, and tools Ismael Juma (JIRA)
• [jira] [Commented] (KAFKA-6930) Update KafkaZkClient debug log ASF GitHub Bot (JIRA)
• [jira] [Updated] (KAFKA-6930) Update KafkaZkClient debug log darion yaphet (JIRA)
  • [jira] [Updated] (KAFKA-6930) Update KafkaZkClient debug log darion yaphet (JIRA)
  • [jira] [Updated] (KAFKA-6930) Update KafkaZkClient debug log darion yaphet (JIRA)
• [jira] [Created] (KAFKA-6930) Update KafkaZkClient debug log darion yaphet (JIRA)
• [jira] [Created] (KAFKA-6929) ZkData - Consumers offsets Zookeeper path is not correct maytal (JIRA)
• [jira] [Resolved] (KAFKA-6892) Kafka Streams memory usage grows over the time till OOM Dawid Kulig (JIRA)
• [jira] [Assigned] (KAFKA-2983) Remove old Scala consumer and all related code, tests, and tools Andras Beni (JIRA)
  • [jira] [Assigned] (KAFKA-2983) Remove old Scala consumer and all related code, tests, and tools Andras Beni (JIRA)
• [jira] [Commented] (KAFKA-1400) transient unit test failure in SocketServerTest ASF GitHub Bot (JIRA)
  • [jira] [Commented] (KAFKA-1400) transient unit test failure in SocketServerTest ASF GitHub Bot (JIRA)
• [jira] [Commented] (KAFKA-6925) Memory leak in org.apache.kafka.streams.processor.internals.StreamThread$StreamsMetricsThreadImpl Guozhang Wang (JIRA)
  • [jira] [Commented] (KAFKA-6925) Memory leak in org.apache.kafka.streams.processor.internals.StreamThread$StreamsMetricsThreadImpl John Roesler (JIRA)
• [jira] [Commented] (KAFKA-6924) Making state store queryable on replicas Guozhang Wang (JIRA)
  • [jira] [Commented] (KAFKA-6924) Making state store queryable on replicas Navinder Brar (JIRA)
• [jira] [Created] (KAFKA-6928) StreamsPartitionAssignor is double retrying within InternalTopicManager Guozhang Wang (JIRA)
• [jira] [Commented] (KAFKA-6927) Broker uses significant amount of memory during down-conversion Dhruvil Shah (JIRA)
• [jira] [Created] (KAFKA-6927) Broker uses significant amount of memory during down-conversion Dhruvil Shah (JIRA)
• [jira] [Commented] (KAFKA-2561) Optionally support OpenSSL for SSL/TLS Ismael Juma (JIRA)
• [jira] [Reopened] (KAFKA-3665) Default ssl.endpoint.identification.algorithm should be https Ismael Juma (JIRA)
• [jira] [Resolved] (KAFKA-3665) Default ssl.endpoint.identification.algorithm should be https Ismael Juma (JIRA)
• [jira] [Updated] (KAFKA-3665) Default ssl.endpoint.identification.algorithm should be https Ismael Juma (JIRA)
• [jira] [Commented] (KAFKA-6562) KIP-255: OAuth Authentication via SASL/OAUTHBEARER Ismael Juma (JIRA)
• [jira] [Commented] (KAFKA-2951) Additional authorization test cases ASF GitHub Bot (JIRA)
• [jira] [Resolved] (KAFKA-6873) Broker is not returning data including requested offset Ismael Juma (JIRA)
• [jira] [Updated] (KAFKA-6873) Broker is not returning data including requested offset Ismael Juma (JIRA)
• [jira] [Resolved] (KAFKA-6839) ZK session retry with cname record Tyler Monahan (JIRA)
• [jira] [Updated] (KAFKA-3816) Provide more context in Kafka Connect log messages using MDC Randall Hauch (JIRA)
• [jira] [Commented] (KAFKA-6926) Reduce NPath exceptions in Connect ASF GitHub Bot (JIRA)
• [jira] [Assigned] (KAFKA-6926) Reduce NPath exceptions in Connect Randall Hauch (JIRA)
• [jira] [Commented] (KAFKA-6868) BufferUnderflowException in client when querying consumer group information ASF GitHub Bot (JIRA)
• [jira] [Created] (KAFKA-6926) Reduce NPath exceptions in Connect Randall Hauch (JIRA)
• [jira] [Updated] (KAFKA-6925) Memory leak in org.apache.kafka.streams.processor.internals.StreamThread$StreamsMetricsThreadImpl Marcin Kuthan (JIRA)
  • [jira] [Updated] (KAFKA-6925) Memory leak in org.apache.kafka.streams.processor.internals.StreamThread$StreamsMetricsThreadImpl Marcin Kuthan (JIRA)
  • [jira] [Updated] (KAFKA-6925) Memory leak in org.apache.kafka.streams.processor.internals.StreamThread$StreamsMetricsThreadImpl John Roesler (JIRA)
  • [jira] [Updated] (KAFKA-6925) Memory leak in org.apache.kafka.streams.processor.internals.StreamThread$StreamsMetricsThreadImpl John Roesler (JIRA)
• [jira] [Created] (KAFKA-6925) Memory leak in org.apache.kafka.streams.processor.internals.StreamThread$StreamsMetricsThreadImpl Marcin Kuthan (JIRA)
• [jira] [Commented] (KAFKA-6916) AdminClient does not refresh metadata on broker failure ASF GitHub Bot (JIRA)
• [jira] [Updated] (KAFKA-6924) Making state store queryable on replicas Navinder Brar (JIRA)
• [jira] [Created] (KAFKA-6924) Making state store queryable on replicas Navinder Brar (JIRA)
• [jira] [Updated] (KAFKA-6923) Consolidate ExtendedSerializer/Serializer and ExtendedDeserializer/Deserializer Ismael Juma (JIRA)
• [jira] [Created] (KAFKA-6923) Deprecate ExtendedSerializer/Serializer and ExtendedDeserializer/Deserializer Ismael Juma (JIRA)
• [jira] [Commented] (KAFKA-6918) Kafka server fails to start with IBM JAVA Ismael Juma (JIRA)
• [jira] [Created] (KAFKA-6922) Rethink WindowedStreamPartitioner configurations Guozhang Wang (JIRA)
• [jira] [Commented] (KAFKA-4423) Drop support for Java 7 ASF GitHub Bot (JIRA)
  • [jira] [Commented] (KAFKA-4423) Drop support for Java 7 ASF GitHub Bot (JIRA)
• [jira] [Commented] (KAFKA-6921) Remove old Scala producer and all related code, tests, and tools ASF GitHub Bot (JIRA)
• [jira] [Updated] (KAFKA-6921) Remove old Scala producer and all related code, tests, and tools Ismael Juma (JIRA)
• [jira] [Created] (KAFKA-6921) Remove old Scala producer and all related code, tests, and tools Ismael Juma (JIRA)
• [jira] [Updated] (KAFKA-2983) Remove old Scala consumer and all related code, tests, and tools. Ismael Juma (JIRA)
• [jira] [Updated] (KAFKA-2983) Remove old Scala consumer and all related code, tests, and tools Ismael Juma (JIRA)
  • [jira] [Updated] (KAFKA-2983) Remove old Scala consumer and all related code, tests, and tools Ismael Juma (JIRA)
• [jira] [Updated] (KAFKA-6920) Enhance ConsumerRecordFactory and OutputVerifier for Header support Matthias J. Sax (JIRA)
• [jira] [Created] (KAFKA-6920) Enhance ConsumerRecordFactory and OutputVerifier for Header support Matthias J. Sax (JIRA)
• [jira] [Commented] (KAFKA-6850) KIP-244: Add Record Header support to Kafka Streams Processor API Matthias J. Sax (JIRA)
  • [jira] [Commented] (KAFKA-6850) KIP-244: Add Record Header support to Kafka Streams Processor API ASF GitHub Bot (JIRA)
• [jira] [Reopened] (KAFKA-5697) StreamThread.shutdown() need to interrupt the stream threads to break the loop Matthias J. Sax (JIRA)
• [jira] [Commented] (KAFKA-6919) Trogdor documentation points to wrong location for trogdor.sh ASF GitHub Bot (JIRA)
• [jira] [Created] (KAFKA-6919) Trogdor documentation points to wrong location for trogdor.sh Koen De Groote (JIRA)
• [jira] [Resolved] (KAFKA-6849) Add transformValues() method to KTable Guozhang Wang (JIRA)
• [jira] [Updated] (KAFKA-6917) Request handler deadlocks attempting to acquire group metadata lock Jason Gustafson (JIRA)
• [jira] [Resolved] (KAFKA-6917) Request handler deadlocks attempting to acquire group metadata lock Jason Gustafson (JIRA)
• [jira] [Updated] (KAFKA-6914) Kafka Connect - Plugins class should have a constructor that can take in parent ClassLoader Sriram KS (JIRA)
• [jira] [Resolved] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll() Ewen Cheslack-Postava (JIRA)
• [jira] [Resolved] (KAFKA-5728) Stopping consumer thread cause loosing message in the partition Manikumar (JIRA)
• [jira] [Created] (KAFKA-6918) Kafka server fails to start with IBM JAVA Nayana Thorat (JIRA)
• [jira] [Commented] (KAFKA-6917) Request handler deadlocks attempting to acquire group metadata lock ASF GitHub Bot (JIRA)
  • [jira] [Commented] (KAFKA-6917) Request handler deadlocks attempting to acquire group metadata lock ASF GitHub Bot (JIRA)
• [jira] [Commented] (KAFKA-6873) Broker is not returning data including requested offset Ismael Juma (JIRA)
  • [jira] [Commented] (KAFKA-6873) Broker is not returning data including requested offset Adam Dratwinski (JIRA)
  • [jira] [Commented] (KAFKA-6873) Broker is not returning data including requested offset Jason Gustafson (JIRA)
  • [jira] [Commented] (KAFKA-6873) Broker is not returning data including requested offset Ismael Juma (JIRA)
• [jira] [Created] (KAFKA-6917) Request handler deadlocks attempting to acquire group metadata lock Rajini Sivaram (JIRA)
• [jira] [Comment Edited] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time Christoph Schmidt (JIRA)
  • [jira] [Comment Edited] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time Christoph Schmidt (JIRA)
• [jira] [Resolved] (KAFKA-4091) Unable to produce or consume on any topic Manikumar (JIRA)

• Earlier messages